Interface EmrContainersClient
- All Superinterfaces:
AutoCloseable
,AwsClient
,SdkAutoCloseable
,SdkClient
builder()
method.
Amazon EMR on EKS provides a deployment option for Amazon EMR that allows you to run open-source big data frameworks on Amazon Elastic Kubernetes Service (Amazon EKS). With this deployment option, you can focus on running analytics workloads while Amazon EMR on EKS builds, configures, and manages containers for open-source applications. For more information about Amazon EMR on EKS concepts and tasks, see What is Amazon EMR on EKS.
Amazon EMR containers is the API name for Amazon EMR on EKS. The emr-containers
prefix is used in
the following scenarios:
-
It is the prefix in the CLI commands for Amazon EMR on EKS. For example,
aws emr-containers start-job-run
. -
It is the prefix before IAM policy actions for Amazon EMR on EKS. For example,
"Action": [ "emr-containers:StartJobRun"]
. For more information, see Policy actions for Amazon EMR on EKS. -
It is the prefix used in Amazon EMR on EKS service endpoints. For example,
emr-containers.us-east-2.amazonaws.com
. For more information, see Amazon EMR on EKSService Endpoints.
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final String
Value for looking up the service's metadata from theServiceMetadataProvider
.static final String
-
Method Summary
Modifier and TypeMethodDescriptionstatic EmrContainersClientBuilder
builder()
Create a builder that can be used to configure and create aEmrContainersClient
.default CancelJobRunResponse
cancelJobRun
(Consumer<CancelJobRunRequest.Builder> cancelJobRunRequest) Cancels a job run.default CancelJobRunResponse
cancelJobRun
(CancelJobRunRequest cancelJobRunRequest) Cancels a job run.static EmrContainersClient
create()
Create aEmrContainersClient
with the region loaded from theDefaultAwsRegionProviderChain
and credentials loaded from theDefaultCredentialsProvider
.default CreateJobTemplateResponse
createJobTemplate
(Consumer<CreateJobTemplateRequest.Builder> createJobTemplateRequest) Creates a job template.default CreateJobTemplateResponse
createJobTemplate
(CreateJobTemplateRequest createJobTemplateRequest) Creates a job template.default CreateManagedEndpointResponse
createManagedEndpoint
(Consumer<CreateManagedEndpointRequest.Builder> createManagedEndpointRequest) Creates a managed endpoint.default CreateManagedEndpointResponse
createManagedEndpoint
(CreateManagedEndpointRequest createManagedEndpointRequest) Creates a managed endpoint.createSecurityConfiguration
(Consumer<CreateSecurityConfigurationRequest.Builder> createSecurityConfigurationRequest) Creates a security configuration.createSecurityConfiguration
(CreateSecurityConfigurationRequest createSecurityConfigurationRequest) Creates a security configuration.default CreateVirtualClusterResponse
createVirtualCluster
(Consumer<CreateVirtualClusterRequest.Builder> createVirtualClusterRequest) Creates a virtual cluster.default CreateVirtualClusterResponse
createVirtualCluster
(CreateVirtualClusterRequest createVirtualClusterRequest) Creates a virtual cluster.default DeleteJobTemplateResponse
deleteJobTemplate
(Consumer<DeleteJobTemplateRequest.Builder> deleteJobTemplateRequest) Deletes a job template.default DeleteJobTemplateResponse
deleteJobTemplate
(DeleteJobTemplateRequest deleteJobTemplateRequest) Deletes a job template.default DeleteManagedEndpointResponse
deleteManagedEndpoint
(Consumer<DeleteManagedEndpointRequest.Builder> deleteManagedEndpointRequest) Deletes a managed endpoint.default DeleteManagedEndpointResponse
deleteManagedEndpoint
(DeleteManagedEndpointRequest deleteManagedEndpointRequest) Deletes a managed endpoint.default DeleteVirtualClusterResponse
deleteVirtualCluster
(Consumer<DeleteVirtualClusterRequest.Builder> deleteVirtualClusterRequest) Deletes a virtual cluster.default DeleteVirtualClusterResponse
deleteVirtualCluster
(DeleteVirtualClusterRequest deleteVirtualClusterRequest) Deletes a virtual cluster.default DescribeJobRunResponse
describeJobRun
(Consumer<DescribeJobRunRequest.Builder> describeJobRunRequest) Displays detailed information about a job run.default DescribeJobRunResponse
describeJobRun
(DescribeJobRunRequest describeJobRunRequest) Displays detailed information about a job run.default DescribeJobTemplateResponse
describeJobTemplate
(Consumer<DescribeJobTemplateRequest.Builder> describeJobTemplateRequest) Displays detailed information about a specified job template.default DescribeJobTemplateResponse
describeJobTemplate
(DescribeJobTemplateRequest describeJobTemplateRequest) Displays detailed information about a specified job template.default DescribeManagedEndpointResponse
describeManagedEndpoint
(Consumer<DescribeManagedEndpointRequest.Builder> describeManagedEndpointRequest) Displays detailed information about a managed endpoint.default DescribeManagedEndpointResponse
describeManagedEndpoint
(DescribeManagedEndpointRequest describeManagedEndpointRequest) Displays detailed information about a managed endpoint.describeSecurityConfiguration
(Consumer<DescribeSecurityConfigurationRequest.Builder> describeSecurityConfigurationRequest) Displays detailed information about a specified security configuration.describeSecurityConfiguration
(DescribeSecurityConfigurationRequest describeSecurityConfigurationRequest) Displays detailed information about a specified security configuration.default DescribeVirtualClusterResponse
describeVirtualCluster
(Consumer<DescribeVirtualClusterRequest.Builder> describeVirtualClusterRequest) Displays detailed information about a specified virtual cluster.default DescribeVirtualClusterResponse
describeVirtualCluster
(DescribeVirtualClusterRequest describeVirtualClusterRequest) Displays detailed information about a specified virtual cluster.getManagedEndpointSessionCredentials
(Consumer<GetManagedEndpointSessionCredentialsRequest.Builder> getManagedEndpointSessionCredentialsRequest) Generate a session token to connect to a managed endpoint.getManagedEndpointSessionCredentials
(GetManagedEndpointSessionCredentialsRequest getManagedEndpointSessionCredentialsRequest) Generate a session token to connect to a managed endpoint.default ListJobRunsResponse
listJobRuns
(Consumer<ListJobRunsRequest.Builder> listJobRunsRequest) Lists job runs based on a set of parameters.default ListJobRunsResponse
listJobRuns
(ListJobRunsRequest listJobRunsRequest) Lists job runs based on a set of parameters.default ListJobRunsIterable
listJobRunsPaginator
(Consumer<ListJobRunsRequest.Builder> listJobRunsRequest) This is a variant oflistJobRuns(software.amazon.awssdk.services.emrcontainers.model.ListJobRunsRequest)
operation.default ListJobRunsIterable
listJobRunsPaginator
(ListJobRunsRequest listJobRunsRequest) This is a variant oflistJobRuns(software.amazon.awssdk.services.emrcontainers.model.ListJobRunsRequest)
operation.default ListJobTemplatesResponse
listJobTemplates
(Consumer<ListJobTemplatesRequest.Builder> listJobTemplatesRequest) Lists job templates based on a set of parameters.default ListJobTemplatesResponse
listJobTemplates
(ListJobTemplatesRequest listJobTemplatesRequest) Lists job templates based on a set of parameters.default ListJobTemplatesIterable
listJobTemplatesPaginator
(Consumer<ListJobTemplatesRequest.Builder> listJobTemplatesRequest) This is a variant oflistJobTemplates(software.amazon.awssdk.services.emrcontainers.model.ListJobTemplatesRequest)
operation.default ListJobTemplatesIterable
listJobTemplatesPaginator
(ListJobTemplatesRequest listJobTemplatesRequest) This is a variant oflistJobTemplates(software.amazon.awssdk.services.emrcontainers.model.ListJobTemplatesRequest)
operation.default ListManagedEndpointsResponse
listManagedEndpoints
(Consumer<ListManagedEndpointsRequest.Builder> listManagedEndpointsRequest) Lists managed endpoints based on a set of parameters.default ListManagedEndpointsResponse
listManagedEndpoints
(ListManagedEndpointsRequest listManagedEndpointsRequest) Lists managed endpoints based on a set of parameters.default ListManagedEndpointsIterable
listManagedEndpointsPaginator
(Consumer<ListManagedEndpointsRequest.Builder> listManagedEndpointsRequest) This is a variant oflistManagedEndpoints(software.amazon.awssdk.services.emrcontainers.model.ListManagedEndpointsRequest)
operation.default ListManagedEndpointsIterable
listManagedEndpointsPaginator
(ListManagedEndpointsRequest listManagedEndpointsRequest) This is a variant oflistManagedEndpoints(software.amazon.awssdk.services.emrcontainers.model.ListManagedEndpointsRequest)
operation.listSecurityConfigurations
(Consumer<ListSecurityConfigurationsRequest.Builder> listSecurityConfigurationsRequest) Lists security configurations based on a set of parameters.listSecurityConfigurations
(ListSecurityConfigurationsRequest listSecurityConfigurationsRequest) Lists security configurations based on a set of parameters.listSecurityConfigurationsPaginator
(Consumer<ListSecurityConfigurationsRequest.Builder> listSecurityConfigurationsRequest) This is a variant oflistSecurityConfigurations(software.amazon.awssdk.services.emrcontainers.model.ListSecurityConfigurationsRequest)
operation.listSecurityConfigurationsPaginator
(ListSecurityConfigurationsRequest listSecurityConfigurationsRequest) This is a variant oflistSecurityConfigurations(software.amazon.awssdk.services.emrcontainers.model.ListSecurityConfigurationsRequest)
operation.default ListTagsForResourceResponse
listTagsForResource
(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest) Lists the tags assigned to the resources.default ListTagsForResourceResponse
listTagsForResource
(ListTagsForResourceRequest listTagsForResourceRequest) Lists the tags assigned to the resources.default ListVirtualClustersResponse
listVirtualClusters
(Consumer<ListVirtualClustersRequest.Builder> listVirtualClustersRequest) Lists information about the specified virtual cluster.default ListVirtualClustersResponse
listVirtualClusters
(ListVirtualClustersRequest listVirtualClustersRequest) Lists information about the specified virtual cluster.default ListVirtualClustersIterable
listVirtualClustersPaginator
(Consumer<ListVirtualClustersRequest.Builder> listVirtualClustersRequest) This is a variant oflistVirtualClusters(software.amazon.awssdk.services.emrcontainers.model.ListVirtualClustersRequest)
operation.default ListVirtualClustersIterable
listVirtualClustersPaginator
(ListVirtualClustersRequest listVirtualClustersRequest) This is a variant oflistVirtualClusters(software.amazon.awssdk.services.emrcontainers.model.ListVirtualClustersRequest)
operation.The SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfigurationstatic ServiceMetadata
default StartJobRunResponse
startJobRun
(Consumer<StartJobRunRequest.Builder> startJobRunRequest) Starts a job run.default StartJobRunResponse
startJobRun
(StartJobRunRequest startJobRunRequest) Starts a job run.default TagResourceResponse
tagResource
(Consumer<TagResourceRequest.Builder> tagResourceRequest) Assigns tags to resources.default TagResourceResponse
tagResource
(TagResourceRequest tagResourceRequest) Assigns tags to resources.default UntagResourceResponse
untagResource
(Consumer<UntagResourceRequest.Builder> untagResourceRequest) Removes tags from resources.default UntagResourceResponse
untagResource
(UntagResourceRequest untagResourceRequest) Removes tags from resources.Methods inherited from interface software.amazon.awssdk.utils.SdkAutoCloseable
close
Methods inherited from interface software.amazon.awssdk.core.SdkClient
serviceName
-
Field Details
-
SERVICE_NAME
- See Also:
-
SERVICE_METADATA_ID
Value for looking up the service's metadata from theServiceMetadataProvider
.- See Also:
-
-
Method Details
-
cancelJobRun
default CancelJobRunResponse cancelJobRun(CancelJobRunRequest cancelJobRunRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Cancels a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
- Parameters:
cancelJobRunRequest
-- Returns:
- Result of the CancelJobRun operation returned by the service.
- See Also:
-
cancelJobRun
default CancelJobRunResponse cancelJobRun(Consumer<CancelJobRunRequest.Builder> cancelJobRunRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Cancels a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
This is a convenience which creates an instance of the
CancelJobRunRequest.Builder
avoiding the need to create one manually viaCancelJobRunRequest.builder()
- Parameters:
cancelJobRunRequest
- AConsumer
that will call methods onCancelJobRunRequest.Builder
to create a request.- Returns:
- Result of the CancelJobRun operation returned by the service.
- See Also:
-
createJobTemplate
default CreateJobTemplateResponse createJobTemplate(CreateJobTemplateRequest createJobTemplateRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Creates a job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
- Parameters:
createJobTemplateRequest
-- Returns:
- Result of the CreateJobTemplate operation returned by the service.
- See Also:
-
createJobTemplate
default CreateJobTemplateResponse createJobTemplate(Consumer<CreateJobTemplateRequest.Builder> createJobTemplateRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Creates a job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
This is a convenience which creates an instance of the
CreateJobTemplateRequest.Builder
avoiding the need to create one manually viaCreateJobTemplateRequest.builder()
- Parameters:
createJobTemplateRequest
- AConsumer
that will call methods onCreateJobTemplateRequest.Builder
to create a request.- Returns:
- Result of the CreateJobTemplate operation returned by the service.
- See Also:
-
createManagedEndpoint
default CreateManagedEndpointResponse createManagedEndpoint(CreateManagedEndpointRequest createManagedEndpointRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Creates a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual cluster.
- Parameters:
createManagedEndpointRequest
-- Returns:
- Result of the CreateManagedEndpoint operation returned by the service.
- See Also:
-
createManagedEndpoint
default CreateManagedEndpointResponse createManagedEndpoint(Consumer<CreateManagedEndpointRequest.Builder> createManagedEndpointRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Creates a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual cluster.
This is a convenience which creates an instance of the
CreateManagedEndpointRequest.Builder
avoiding the need to create one manually viaCreateManagedEndpointRequest.builder()
- Parameters:
createManagedEndpointRequest
- AConsumer
that will call methods onCreateManagedEndpointRequest.Builder
to create a request.- Returns:
- Result of the CreateManagedEndpoint operation returned by the service.
- See Also:
-
createSecurityConfiguration
default CreateSecurityConfigurationResponse createSecurityConfiguration(CreateSecurityConfigurationRequest createSecurityConfigurationRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Creates a security configuration. Security configurations in Amazon EMR on EKS are templates for different security setups. You can use security configurations to configure the Lake Formation integration setup. You can also create a security configuration to re-use a security setup each time you create a virtual cluster.
- Parameters:
createSecurityConfigurationRequest
-- Returns:
- Result of the CreateSecurityConfiguration operation returned by the service.
- See Also:
-
createSecurityConfiguration
default CreateSecurityConfigurationResponse createSecurityConfiguration(Consumer<CreateSecurityConfigurationRequest.Builder> createSecurityConfigurationRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Creates a security configuration. Security configurations in Amazon EMR on EKS are templates for different security setups. You can use security configurations to configure the Lake Formation integration setup. You can also create a security configuration to re-use a security setup each time you create a virtual cluster.
This is a convenience which creates an instance of the
CreateSecurityConfigurationRequest.Builder
avoiding the need to create one manually viaCreateSecurityConfigurationRequest.builder()
- Parameters:
createSecurityConfigurationRequest
- AConsumer
that will call methods onCreateSecurityConfigurationRequest.Builder
to create a request.- Returns:
- Result of the CreateSecurityConfiguration operation returned by the service.
- See Also:
-
createVirtualCluster
default CreateVirtualClusterResponse createVirtualCluster(CreateVirtualClusterRequest createVirtualClusterRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, EksRequestThrottledException, AwsServiceException, SdkClientException, EmrContainersException Creates a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
- Parameters:
createVirtualClusterRequest
-- Returns:
- Result of the CreateVirtualCluster operation returned by the service.
- See Also:
-
createVirtualCluster
default CreateVirtualClusterResponse createVirtualCluster(Consumer<CreateVirtualClusterRequest.Builder> createVirtualClusterRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, EksRequestThrottledException, AwsServiceException, SdkClientException, EmrContainersException Creates a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
This is a convenience which creates an instance of the
CreateVirtualClusterRequest.Builder
avoiding the need to create one manually viaCreateVirtualClusterRequest.builder()
- Parameters:
createVirtualClusterRequest
- AConsumer
that will call methods onCreateVirtualClusterRequest.Builder
to create a request.- Returns:
- Result of the CreateVirtualCluster operation returned by the service.
- See Also:
-
deleteJobTemplate
default DeleteJobTemplateResponse deleteJobTemplate(DeleteJobTemplateRequest deleteJobTemplateRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Deletes a job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
- Parameters:
deleteJobTemplateRequest
-- Returns:
- Result of the DeleteJobTemplate operation returned by the service.
- See Also:
-
deleteJobTemplate
default DeleteJobTemplateResponse deleteJobTemplate(Consumer<DeleteJobTemplateRequest.Builder> deleteJobTemplateRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Deletes a job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
This is a convenience which creates an instance of the
DeleteJobTemplateRequest.Builder
avoiding the need to create one manually viaDeleteJobTemplateRequest.builder()
- Parameters:
deleteJobTemplateRequest
- AConsumer
that will call methods onDeleteJobTemplateRequest.Builder
to create a request.- Returns:
- Result of the DeleteJobTemplate operation returned by the service.
- See Also:
-
deleteManagedEndpoint
default DeleteManagedEndpointResponse deleteManagedEndpoint(DeleteManagedEndpointRequest deleteManagedEndpointRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Deletes a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual cluster.
- Parameters:
deleteManagedEndpointRequest
-- Returns:
- Result of the DeleteManagedEndpoint operation returned by the service.
- See Also:
-
deleteManagedEndpoint
default DeleteManagedEndpointResponse deleteManagedEndpoint(Consumer<DeleteManagedEndpointRequest.Builder> deleteManagedEndpointRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Deletes a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual cluster.
This is a convenience which creates an instance of the
DeleteManagedEndpointRequest.Builder
avoiding the need to create one manually viaDeleteManagedEndpointRequest.builder()
- Parameters:
deleteManagedEndpointRequest
- AConsumer
that will call methods onDeleteManagedEndpointRequest.Builder
to create a request.- Returns:
- Result of the DeleteManagedEndpoint operation returned by the service.
- See Also:
-
deleteVirtualCluster
default DeleteVirtualClusterResponse deleteVirtualCluster(DeleteVirtualClusterRequest deleteVirtualClusterRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Deletes a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
- Parameters:
deleteVirtualClusterRequest
-- Returns:
- Result of the DeleteVirtualCluster operation returned by the service.
- See Also:
-
deleteVirtualCluster
default DeleteVirtualClusterResponse deleteVirtualCluster(Consumer<DeleteVirtualClusterRequest.Builder> deleteVirtualClusterRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Deletes a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
This is a convenience which creates an instance of the
DeleteVirtualClusterRequest.Builder
avoiding the need to create one manually viaDeleteVirtualClusterRequest.builder()
- Parameters:
deleteVirtualClusterRequest
- AConsumer
that will call methods onDeleteVirtualClusterRequest.Builder
to create a request.- Returns:
- Result of the DeleteVirtualCluster operation returned by the service.
- See Also:
-
describeJobRun
default DescribeJobRunResponse describeJobRun(DescribeJobRunRequest describeJobRunRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
- Parameters:
describeJobRunRequest
-- Returns:
- Result of the DescribeJobRun operation returned by the service.
- See Also:
-
describeJobRun
default DescribeJobRunResponse describeJobRun(Consumer<DescribeJobRunRequest.Builder> describeJobRunRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
This is a convenience which creates an instance of the
DescribeJobRunRequest.Builder
avoiding the need to create one manually viaDescribeJobRunRequest.builder()
- Parameters:
describeJobRunRequest
- AConsumer
that will call methods onDescribeJobRunRequest.Builder
to create a request.- Returns:
- Result of the DescribeJobRun operation returned by the service.
- See Also:
-
describeJobTemplate
default DescribeJobTemplateResponse describeJobTemplate(DescribeJobTemplateRequest describeJobTemplateRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a specified job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
- Parameters:
describeJobTemplateRequest
-- Returns:
- Result of the DescribeJobTemplate operation returned by the service.
- See Also:
-
describeJobTemplate
default DescribeJobTemplateResponse describeJobTemplate(Consumer<DescribeJobTemplateRequest.Builder> describeJobTemplateRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a specified job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
This is a convenience which creates an instance of the
DescribeJobTemplateRequest.Builder
avoiding the need to create one manually viaDescribeJobTemplateRequest.builder()
- Parameters:
describeJobTemplateRequest
- AConsumer
that will call methods onDescribeJobTemplateRequest.Builder
to create a request.- Returns:
- Result of the DescribeJobTemplate operation returned by the service.
- See Also:
-
describeManagedEndpoint
default DescribeManagedEndpointResponse describeManagedEndpoint(DescribeManagedEndpointRequest describeManagedEndpointRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual cluster.
- Parameters:
describeManagedEndpointRequest
-- Returns:
- Result of the DescribeManagedEndpoint operation returned by the service.
- See Also:
-
describeManagedEndpoint
default DescribeManagedEndpointResponse describeManagedEndpoint(Consumer<DescribeManagedEndpointRequest.Builder> describeManagedEndpointRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual cluster.
This is a convenience which creates an instance of the
DescribeManagedEndpointRequest.Builder
avoiding the need to create one manually viaDescribeManagedEndpointRequest.builder()
- Parameters:
describeManagedEndpointRequest
- AConsumer
that will call methods onDescribeManagedEndpointRequest.Builder
to create a request.- Returns:
- Result of the DescribeManagedEndpoint operation returned by the service.
- See Also:
-
describeSecurityConfiguration
default DescribeSecurityConfigurationResponse describeSecurityConfiguration(DescribeSecurityConfigurationRequest describeSecurityConfigurationRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a specified security configuration. Security configurations in Amazon EMR on EKS are templates for different security setups. You can use security configurations to configure the Lake Formation integration setup. You can also create a security configuration to re-use a security setup each time you create a virtual cluster.
- Parameters:
describeSecurityConfigurationRequest
-- Returns:
- Result of the DescribeSecurityConfiguration operation returned by the service.
- See Also:
-
describeSecurityConfiguration
default DescribeSecurityConfigurationResponse describeSecurityConfiguration(Consumer<DescribeSecurityConfigurationRequest.Builder> describeSecurityConfigurationRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a specified security configuration. Security configurations in Amazon EMR on EKS are templates for different security setups. You can use security configurations to configure the Lake Formation integration setup. You can also create a security configuration to re-use a security setup each time you create a virtual cluster.
This is a convenience which creates an instance of the
DescribeSecurityConfigurationRequest.Builder
avoiding the need to create one manually viaDescribeSecurityConfigurationRequest.builder()
- Parameters:
describeSecurityConfigurationRequest
- AConsumer
that will call methods onDescribeSecurityConfigurationRequest.Builder
to create a request.- Returns:
- Result of the DescribeSecurityConfiguration operation returned by the service.
- See Also:
-
describeVirtualCluster
default DescribeVirtualClusterResponse describeVirtualCluster(DescribeVirtualClusterRequest describeVirtualClusterRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a specified virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
- Parameters:
describeVirtualClusterRequest
-- Returns:
- Result of the DescribeVirtualCluster operation returned by the service.
- See Also:
-
describeVirtualCluster
default DescribeVirtualClusterResponse describeVirtualCluster(Consumer<DescribeVirtualClusterRequest.Builder> describeVirtualClusterRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Displays detailed information about a specified virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
This is a convenience which creates an instance of the
DescribeVirtualClusterRequest.Builder
avoiding the need to create one manually viaDescribeVirtualClusterRequest.builder()
- Parameters:
describeVirtualClusterRequest
- AConsumer
that will call methods onDescribeVirtualClusterRequest.Builder
to create a request.- Returns:
- Result of the DescribeVirtualCluster operation returned by the service.
- See Also:
-
getManagedEndpointSessionCredentials
default GetManagedEndpointSessionCredentialsResponse getManagedEndpointSessionCredentials(GetManagedEndpointSessionCredentialsRequest getManagedEndpointSessionCredentialsRequest) throws ValidationException, RequestThrottledException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Generate a session token to connect to a managed endpoint.
- Parameters:
getManagedEndpointSessionCredentialsRequest
-- Returns:
- Result of the GetManagedEndpointSessionCredentials operation returned by the service.
- See Also:
-
getManagedEndpointSessionCredentials
default GetManagedEndpointSessionCredentialsResponse getManagedEndpointSessionCredentials(Consumer<GetManagedEndpointSessionCredentialsRequest.Builder> getManagedEndpointSessionCredentialsRequest) throws ValidationException, RequestThrottledException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Generate a session token to connect to a managed endpoint.
This is a convenience which creates an instance of the
GetManagedEndpointSessionCredentialsRequest.Builder
avoiding the need to create one manually viaGetManagedEndpointSessionCredentialsRequest.builder()
- Parameters:
getManagedEndpointSessionCredentialsRequest
- AConsumer
that will call methods onGetManagedEndpointSessionCredentialsRequest.Builder
to create a request.- Returns:
- Result of the GetManagedEndpointSessionCredentials operation returned by the service.
- See Also:
-
listJobRuns
default ListJobRunsResponse listJobRuns(ListJobRunsRequest listJobRunsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists job runs based on a set of parameters. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
- Parameters:
listJobRunsRequest
-- Returns:
- Result of the ListJobRuns operation returned by the service.
- See Also:
-
listJobRuns
default ListJobRunsResponse listJobRuns(Consumer<ListJobRunsRequest.Builder> listJobRunsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists job runs based on a set of parameters. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
This is a convenience which creates an instance of the
ListJobRunsRequest.Builder
avoiding the need to create one manually viaListJobRunsRequest.builder()
- Parameters:
listJobRunsRequest
- AConsumer
that will call methods onListJobRunsRequest.Builder
to create a request.- Returns:
- Result of the ListJobRuns operation returned by the service.
- See Also:
-
listJobRunsPaginator
default ListJobRunsIterable listJobRunsPaginator(ListJobRunsRequest listJobRunsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listJobRuns(software.amazon.awssdk.services.emrcontainers.model.ListJobRunsRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListJobRunsIterable responses = client.listJobRunsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListJobRunsIterable responses = client.listJobRunsPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListJobRunsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListJobRunsIterable responses = client.listJobRunsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listJobRuns(software.amazon.awssdk.services.emrcontainers.model.ListJobRunsRequest)
operation.- Parameters:
listJobRunsRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listJobRunsPaginator
default ListJobRunsIterable listJobRunsPaginator(Consumer<ListJobRunsRequest.Builder> listJobRunsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listJobRuns(software.amazon.awssdk.services.emrcontainers.model.ListJobRunsRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListJobRunsIterable responses = client.listJobRunsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListJobRunsIterable responses = client.listJobRunsPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListJobRunsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListJobRunsIterable responses = client.listJobRunsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listJobRuns(software.amazon.awssdk.services.emrcontainers.model.ListJobRunsRequest)
operation.
This is a convenience which creates an instance of the
ListJobRunsRequest.Builder
avoiding the need to create one manually viaListJobRunsRequest.builder()
- Parameters:
listJobRunsRequest
- AConsumer
that will call methods onListJobRunsRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listJobTemplates
default ListJobTemplatesResponse listJobTemplates(ListJobTemplatesRequest listJobTemplatesRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists job templates based on a set of parameters. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
- Parameters:
listJobTemplatesRequest
-- Returns:
- Result of the ListJobTemplates operation returned by the service.
- See Also:
-
listJobTemplates
default ListJobTemplatesResponse listJobTemplates(Consumer<ListJobTemplatesRequest.Builder> listJobTemplatesRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists job templates based on a set of parameters. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
This is a convenience which creates an instance of the
ListJobTemplatesRequest.Builder
avoiding the need to create one manually viaListJobTemplatesRequest.builder()
- Parameters:
listJobTemplatesRequest
- AConsumer
that will call methods onListJobTemplatesRequest.Builder
to create a request.- Returns:
- Result of the ListJobTemplates operation returned by the service.
- See Also:
-
listJobTemplatesPaginator
default ListJobTemplatesIterable listJobTemplatesPaginator(ListJobTemplatesRequest listJobTemplatesRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listJobTemplates(software.amazon.awssdk.services.emrcontainers.model.ListJobTemplatesRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListJobTemplatesIterable responses = client.listJobTemplatesPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListJobTemplatesIterable responses = client .listJobTemplatesPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListJobTemplatesResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListJobTemplatesIterable responses = client.listJobTemplatesPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listJobTemplates(software.amazon.awssdk.services.emrcontainers.model.ListJobTemplatesRequest)
operation.- Parameters:
listJobTemplatesRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listJobTemplatesPaginator
default ListJobTemplatesIterable listJobTemplatesPaginator(Consumer<ListJobTemplatesRequest.Builder> listJobTemplatesRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listJobTemplates(software.amazon.awssdk.services.emrcontainers.model.ListJobTemplatesRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListJobTemplatesIterable responses = client.listJobTemplatesPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListJobTemplatesIterable responses = client .listJobTemplatesPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListJobTemplatesResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListJobTemplatesIterable responses = client.listJobTemplatesPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listJobTemplates(software.amazon.awssdk.services.emrcontainers.model.ListJobTemplatesRequest)
operation.
This is a convenience which creates an instance of the
ListJobTemplatesRequest.Builder
avoiding the need to create one manually viaListJobTemplatesRequest.builder()
- Parameters:
listJobTemplatesRequest
- AConsumer
that will call methods onListJobTemplatesRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listManagedEndpoints
default ListManagedEndpointsResponse listManagedEndpoints(ListManagedEndpointsRequest listManagedEndpointsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists managed endpoints based on a set of parameters. A managed endpoint is a gateway that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual cluster.
- Parameters:
listManagedEndpointsRequest
-- Returns:
- Result of the ListManagedEndpoints operation returned by the service.
- See Also:
-
listManagedEndpoints
default ListManagedEndpointsResponse listManagedEndpoints(Consumer<ListManagedEndpointsRequest.Builder> listManagedEndpointsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists managed endpoints based on a set of parameters. A managed endpoint is a gateway that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual cluster.
This is a convenience which creates an instance of the
ListManagedEndpointsRequest.Builder
avoiding the need to create one manually viaListManagedEndpointsRequest.builder()
- Parameters:
listManagedEndpointsRequest
- AConsumer
that will call methods onListManagedEndpointsRequest.Builder
to create a request.- Returns:
- Result of the ListManagedEndpoints operation returned by the service.
- See Also:
-
listManagedEndpointsPaginator
default ListManagedEndpointsIterable listManagedEndpointsPaginator(ListManagedEndpointsRequest listManagedEndpointsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listManagedEndpoints(software.amazon.awssdk.services.emrcontainers.model.ListManagedEndpointsRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListManagedEndpointsIterable responses = client.listManagedEndpointsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListManagedEndpointsIterable responses = client .listManagedEndpointsPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListManagedEndpointsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListManagedEndpointsIterable responses = client.listManagedEndpointsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listManagedEndpoints(software.amazon.awssdk.services.emrcontainers.model.ListManagedEndpointsRequest)
operation.- Parameters:
listManagedEndpointsRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listManagedEndpointsPaginator
default ListManagedEndpointsIterable listManagedEndpointsPaginator(Consumer<ListManagedEndpointsRequest.Builder> listManagedEndpointsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listManagedEndpoints(software.amazon.awssdk.services.emrcontainers.model.ListManagedEndpointsRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListManagedEndpointsIterable responses = client.listManagedEndpointsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListManagedEndpointsIterable responses = client .listManagedEndpointsPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListManagedEndpointsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListManagedEndpointsIterable responses = client.listManagedEndpointsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listManagedEndpoints(software.amazon.awssdk.services.emrcontainers.model.ListManagedEndpointsRequest)
operation.
This is a convenience which creates an instance of the
ListManagedEndpointsRequest.Builder
avoiding the need to create one manually viaListManagedEndpointsRequest.builder()
- Parameters:
listManagedEndpointsRequest
- AConsumer
that will call methods onListManagedEndpointsRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listSecurityConfigurations
default ListSecurityConfigurationsResponse listSecurityConfigurations(ListSecurityConfigurationsRequest listSecurityConfigurationsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists security configurations based on a set of parameters. Security configurations in Amazon EMR on EKS are templates for different security setups. You can use security configurations to configure the Lake Formation integration setup. You can also create a security configuration to re-use a security setup each time you create a virtual cluster.
- Parameters:
listSecurityConfigurationsRequest
-- Returns:
- Result of the ListSecurityConfigurations operation returned by the service.
- See Also:
-
listSecurityConfigurations
default ListSecurityConfigurationsResponse listSecurityConfigurations(Consumer<ListSecurityConfigurationsRequest.Builder> listSecurityConfigurationsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists security configurations based on a set of parameters. Security configurations in Amazon EMR on EKS are templates for different security setups. You can use security configurations to configure the Lake Formation integration setup. You can also create a security configuration to re-use a security setup each time you create a virtual cluster.
This is a convenience which creates an instance of the
ListSecurityConfigurationsRequest.Builder
avoiding the need to create one manually viaListSecurityConfigurationsRequest.builder()
- Parameters:
listSecurityConfigurationsRequest
- AConsumer
that will call methods onListSecurityConfigurationsRequest.Builder
to create a request.- Returns:
- Result of the ListSecurityConfigurations operation returned by the service.
- See Also:
-
listSecurityConfigurationsPaginator
default ListSecurityConfigurationsIterable listSecurityConfigurationsPaginator(ListSecurityConfigurationsRequest listSecurityConfigurationsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listSecurityConfigurations(software.amazon.awssdk.services.emrcontainers.model.ListSecurityConfigurationsRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListSecurityConfigurationsIterable responses = client .listSecurityConfigurationsPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListSecurityConfigurationsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listSecurityConfigurations(software.amazon.awssdk.services.emrcontainers.model.ListSecurityConfigurationsRequest)
operation.- Parameters:
listSecurityConfigurationsRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listSecurityConfigurationsPaginator
default ListSecurityConfigurationsIterable listSecurityConfigurationsPaginator(Consumer<ListSecurityConfigurationsRequest.Builder> listSecurityConfigurationsRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listSecurityConfigurations(software.amazon.awssdk.services.emrcontainers.model.ListSecurityConfigurationsRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListSecurityConfigurationsIterable responses = client .listSecurityConfigurationsPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListSecurityConfigurationsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listSecurityConfigurations(software.amazon.awssdk.services.emrcontainers.model.ListSecurityConfigurationsRequest)
operation.
This is a convenience which creates an instance of the
ListSecurityConfigurationsRequest.Builder
avoiding the need to create one manually viaListSecurityConfigurationsRequest.builder()
- Parameters:
listSecurityConfigurationsRequest
- AConsumer
that will call methods onListSecurityConfigurationsRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listTagsForResource
default ListTagsForResourceResponse listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest) throws InternalServerException, ValidationException, ResourceNotFoundException, AwsServiceException, SdkClientException, EmrContainersException Lists the tags assigned to the resources.
- Parameters:
listTagsForResourceRequest
-- Returns:
- Result of the ListTagsForResource operation returned by the service.
- See Also:
-
listTagsForResource
default ListTagsForResourceResponse listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest) throws InternalServerException, ValidationException, ResourceNotFoundException, AwsServiceException, SdkClientException, EmrContainersException Lists the tags assigned to the resources.
This is a convenience which creates an instance of the
ListTagsForResourceRequest.Builder
avoiding the need to create one manually viaListTagsForResourceRequest.builder()
- Parameters:
listTagsForResourceRequest
- AConsumer
that will call methods onListTagsForResourceRequest.Builder
to create a request.- Returns:
- Result of the ListTagsForResource operation returned by the service.
- See Also:
-
listVirtualClusters
default ListVirtualClustersResponse listVirtualClusters(ListVirtualClustersRequest listVirtualClustersRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists information about the specified virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
- Parameters:
listVirtualClustersRequest
-- Returns:
- Result of the ListVirtualClusters operation returned by the service.
- See Also:
-
listVirtualClusters
default ListVirtualClustersResponse listVirtualClusters(Consumer<ListVirtualClustersRequest.Builder> listVirtualClustersRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Lists information about the specified virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
This is a convenience which creates an instance of the
ListVirtualClustersRequest.Builder
avoiding the need to create one manually viaListVirtualClustersRequest.builder()
- Parameters:
listVirtualClustersRequest
- AConsumer
that will call methods onListVirtualClustersRequest.Builder
to create a request.- Returns:
- Result of the ListVirtualClusters operation returned by the service.
- See Also:
-
listVirtualClustersPaginator
default ListVirtualClustersIterable listVirtualClustersPaginator(ListVirtualClustersRequest listVirtualClustersRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listVirtualClusters(software.amazon.awssdk.services.emrcontainers.model.ListVirtualClustersRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListVirtualClustersIterable responses = client.listVirtualClustersPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListVirtualClustersIterable responses = client .listVirtualClustersPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListVirtualClustersResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListVirtualClustersIterable responses = client.listVirtualClustersPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listVirtualClusters(software.amazon.awssdk.services.emrcontainers.model.ListVirtualClustersRequest)
operation.- Parameters:
listVirtualClustersRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listVirtualClustersPaginator
default ListVirtualClustersIterable listVirtualClustersPaginator(Consumer<ListVirtualClustersRequest.Builder> listVirtualClustersRequest) throws ValidationException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException This is a variant of
listVirtualClusters(software.amazon.awssdk.services.emrcontainers.model.ListVirtualClustersRequest)
operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.
The following are few ways to iterate through the response pages:
1) Using a Streamsoftware.amazon.awssdk.services.emrcontainers.paginators.ListVirtualClustersIterable responses = client.listVirtualClustersPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emrcontainers.paginators.ListVirtualClustersIterable responses = client .listVirtualClustersPaginator(request); for (software.amazon.awssdk.services.emrcontainers.model.ListVirtualClustersResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emrcontainers.paginators.ListVirtualClustersIterable responses = client.listVirtualClustersPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of maxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.
Note: If you prefer to have control on service calls, use the
listVirtualClusters(software.amazon.awssdk.services.emrcontainers.model.ListVirtualClustersRequest)
operation.
This is a convenience which creates an instance of the
ListVirtualClustersRequest.Builder
avoiding the need to create one manually viaListVirtualClustersRequest.builder()
- Parameters:
listVirtualClustersRequest
- AConsumer
that will call methods onListVirtualClustersRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
startJobRun
default StartJobRunResponse startJobRun(StartJobRunRequest startJobRunRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Starts a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
- Parameters:
startJobRunRequest
-- Returns:
- Result of the StartJobRun operation returned by the service.
- See Also:
-
startJobRun
default StartJobRunResponse startJobRun(Consumer<StartJobRunRequest.Builder> startJobRunRequest) throws ValidationException, ResourceNotFoundException, InternalServerException, AwsServiceException, SdkClientException, EmrContainersException Starts a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
This is a convenience which creates an instance of the
StartJobRunRequest.Builder
avoiding the need to create one manually viaStartJobRunRequest.builder()
- Parameters:
startJobRunRequest
- AConsumer
that will call methods onStartJobRunRequest.Builder
to create a request.- Returns:
- Result of the StartJobRun operation returned by the service.
- See Also:
-
tagResource
default TagResourceResponse tagResource(TagResourceRequest tagResourceRequest) throws InternalServerException, ValidationException, ResourceNotFoundException, AwsServiceException, SdkClientException, EmrContainersException Assigns tags to resources. A tag is a label that you assign to an Amazon Web Services resource. Each tag consists of a key and an optional value, both of which you define. Tags enable you to categorize your Amazon Web Services resources by attributes such as purpose, owner, or environment. When you have many resources of the same type, you can quickly identify a specific resource based on the tags you've assigned to it. For example, you can define a set of tags for your Amazon EMR on EKS clusters to help you track each cluster's owner and stack level. We recommend that you devise a consistent set of tag keys for each resource type. You can then search and filter the resources based on the tags that you add.
- Parameters:
tagResourceRequest
-- Returns:
- Result of the TagResource operation returned by the service.
- See Also:
-
tagResource
default TagResourceResponse tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest) throws InternalServerException, ValidationException, ResourceNotFoundException, AwsServiceException, SdkClientException, EmrContainersException Assigns tags to resources. A tag is a label that you assign to an Amazon Web Services resource. Each tag consists of a key and an optional value, both of which you define. Tags enable you to categorize your Amazon Web Services resources by attributes such as purpose, owner, or environment. When you have many resources of the same type, you can quickly identify a specific resource based on the tags you've assigned to it. For example, you can define a set of tags for your Amazon EMR on EKS clusters to help you track each cluster's owner and stack level. We recommend that you devise a consistent set of tag keys for each resource type. You can then search and filter the resources based on the tags that you add.
This is a convenience which creates an instance of the
TagResourceRequest.Builder
avoiding the need to create one manually viaTagResourceRequest.builder()
- Parameters:
tagResourceRequest
- AConsumer
that will call methods onTagResourceRequest.Builder
to create a request.- Returns:
- Result of the TagResource operation returned by the service.
- See Also:
-
untagResource
default UntagResourceResponse untagResource(UntagResourceRequest untagResourceRequest) throws InternalServerException, ValidationException, ResourceNotFoundException, AwsServiceException, SdkClientException, EmrContainersException Removes tags from resources.
- Parameters:
untagResourceRequest
-- Returns:
- Result of the UntagResource operation returned by the service.
- See Also:
-
untagResource
default UntagResourceResponse untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest) throws InternalServerException, ValidationException, ResourceNotFoundException, AwsServiceException, SdkClientException, EmrContainersException Removes tags from resources.
This is a convenience which creates an instance of the
UntagResourceRequest.Builder
avoiding the need to create one manually viaUntagResourceRequest.builder()
- Parameters:
untagResourceRequest
- AConsumer
that will call methods onUntagResourceRequest.Builder
to create a request.- Returns:
- Result of the UntagResource operation returned by the service.
- See Also:
-
create
Create aEmrContainersClient
with the region loaded from theDefaultAwsRegionProviderChain
and credentials loaded from theDefaultCredentialsProvider
. -
builder
Create a builder that can be used to configure and create aEmrContainersClient
. -
serviceMetadata
-
serviceClientConfiguration
Description copied from interface:SdkClient
The SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfiguration- Specified by:
serviceClientConfiguration
in interfaceAwsClient
- Specified by:
serviceClientConfiguration
in interfaceSdkClient
- Returns:
- SdkServiceClientConfiguration
-