Interface EmrClient
- All Superinterfaces:
AutoCloseable
,AwsClient
,SdkAutoCloseable
,SdkClient
builder()
method.
Amazon EMR is a web service that makes it easier to process large amounts of data efficiently. Amazon EMR uses Hadoop processing combined with several Amazon Web Services services to do tasks such as web indexing, data mining, log file analysis, machine learning, scientific simulation, and data warehouse management.
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final String
Value for looking up the service's metadata from theServiceMetadataProvider
.static final String
-
Method Summary
Modifier and TypeMethodDescriptiondefault AddInstanceFleetResponse
addInstanceFleet
(Consumer<AddInstanceFleetRequest.Builder> addInstanceFleetRequest) Adds an instance fleet to a running cluster.default AddInstanceFleetResponse
addInstanceFleet
(AddInstanceFleetRequest addInstanceFleetRequest) Adds an instance fleet to a running cluster.default AddInstanceGroupsResponse
addInstanceGroups
(Consumer<AddInstanceGroupsRequest.Builder> addInstanceGroupsRequest) Adds one or more instance groups to a running cluster.default AddInstanceGroupsResponse
addInstanceGroups
(AddInstanceGroupsRequest addInstanceGroupsRequest) Adds one or more instance groups to a running cluster.default AddJobFlowStepsResponse
addJobFlowSteps
(Consumer<AddJobFlowStepsRequest.Builder> addJobFlowStepsRequest) AddJobFlowSteps adds new steps to a running cluster.default AddJobFlowStepsResponse
addJobFlowSteps
(AddJobFlowStepsRequest addJobFlowStepsRequest) AddJobFlowSteps adds new steps to a running cluster.default AddTagsResponse
addTags
(Consumer<AddTagsRequest.Builder> addTagsRequest) Adds tags to an Amazon EMR resource, such as a cluster or an Amazon EMR Studio.default AddTagsResponse
addTags
(AddTagsRequest addTagsRequest) Adds tags to an Amazon EMR resource, such as a cluster or an Amazon EMR Studio.static EmrClientBuilder
builder()
Create a builder that can be used to configure and create aEmrClient
.default CancelStepsResponse
cancelSteps
(Consumer<CancelStepsRequest.Builder> cancelStepsRequest) Cancels a pending step or steps in a running cluster.default CancelStepsResponse
cancelSteps
(CancelStepsRequest cancelStepsRequest) Cancels a pending step or steps in a running cluster.static EmrClient
create()
Create aEmrClient
with the region loaded from theDefaultAwsRegionProviderChain
and credentials loaded from theDefaultCredentialsProvider
.createSecurityConfiguration
(Consumer<CreateSecurityConfigurationRequest.Builder> createSecurityConfigurationRequest) Creates a security configuration, which is stored in the service and can be specified when a cluster is created.createSecurityConfiguration
(CreateSecurityConfigurationRequest createSecurityConfigurationRequest) Creates a security configuration, which is stored in the service and can be specified when a cluster is created.default CreateStudioResponse
createStudio
(Consumer<CreateStudioRequest.Builder> createStudioRequest) Creates a new Amazon EMR Studio.default CreateStudioResponse
createStudio
(CreateStudioRequest createStudioRequest) Creates a new Amazon EMR Studio.createStudioSessionMapping
(Consumer<CreateStudioSessionMappingRequest.Builder> createStudioSessionMappingRequest) Maps a user or group to the Amazon EMR Studio specified byStudioId
, and applies a session policy to refine Studio permissions for that user or group.createStudioSessionMapping
(CreateStudioSessionMappingRequest createStudioSessionMappingRequest) Maps a user or group to the Amazon EMR Studio specified byStudioId
, and applies a session policy to refine Studio permissions for that user or group.deleteSecurityConfiguration
(Consumer<DeleteSecurityConfigurationRequest.Builder> deleteSecurityConfigurationRequest) Deletes a security configuration.deleteSecurityConfiguration
(DeleteSecurityConfigurationRequest deleteSecurityConfigurationRequest) Deletes a security configuration.default DeleteStudioResponse
deleteStudio
(Consumer<DeleteStudioRequest.Builder> deleteStudioRequest) Removes an Amazon EMR Studio from the Studio metadata store.default DeleteStudioResponse
deleteStudio
(DeleteStudioRequest deleteStudioRequest) Removes an Amazon EMR Studio from the Studio metadata store.deleteStudioSessionMapping
(Consumer<DeleteStudioSessionMappingRequest.Builder> deleteStudioSessionMappingRequest) Removes a user or group from an Amazon EMR Studio.deleteStudioSessionMapping
(DeleteStudioSessionMappingRequest deleteStudioSessionMappingRequest) Removes a user or group from an Amazon EMR Studio.default DescribeClusterResponse
describeCluster
(Consumer<DescribeClusterRequest.Builder> describeClusterRequest) Provides cluster-level details including status, hardware and software configuration, VPC settings, and so on.default DescribeClusterResponse
describeCluster
(DescribeClusterRequest describeClusterRequest) Provides cluster-level details including status, hardware and software configuration, VPC settings, and so on.describeNotebookExecution
(Consumer<DescribeNotebookExecutionRequest.Builder> describeNotebookExecutionRequest) Provides details of a notebook execution.describeNotebookExecution
(DescribeNotebookExecutionRequest describeNotebookExecutionRequest) Provides details of a notebook execution.default DescribeReleaseLabelResponse
describeReleaseLabel
(Consumer<DescribeReleaseLabelRequest.Builder> describeReleaseLabelRequest) Provides Amazon EMR release label details, such as the releases available the Region where the API request is run, and the available applications for a specific Amazon EMR release label.default DescribeReleaseLabelResponse
describeReleaseLabel
(DescribeReleaseLabelRequest describeReleaseLabelRequest) Provides Amazon EMR release label details, such as the releases available the Region where the API request is run, and the available applications for a specific Amazon EMR release label.describeSecurityConfiguration
(Consumer<DescribeSecurityConfigurationRequest.Builder> describeSecurityConfigurationRequest) Provides the details of a security configuration by returning the configuration JSON.describeSecurityConfiguration
(DescribeSecurityConfigurationRequest describeSecurityConfigurationRequest) Provides the details of a security configuration by returning the configuration JSON.default DescribeStepResponse
describeStep
(Consumer<DescribeStepRequest.Builder> describeStepRequest) Provides more detail about the cluster step.default DescribeStepResponse
describeStep
(DescribeStepRequest describeStepRequest) Provides more detail about the cluster step.default DescribeStudioResponse
describeStudio
(Consumer<DescribeStudioRequest.Builder> describeStudioRequest) Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio access URL, and so on.default DescribeStudioResponse
describeStudio
(DescribeStudioRequest describeStudioRequest) Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio access URL, and so on.default GetAutoTerminationPolicyResponse
getAutoTerminationPolicy
(Consumer<GetAutoTerminationPolicyRequest.Builder> getAutoTerminationPolicyRequest) Returns the auto-termination policy for an Amazon EMR cluster.default GetAutoTerminationPolicyResponse
getAutoTerminationPolicy
(GetAutoTerminationPolicyRequest getAutoTerminationPolicyRequest) Returns the auto-termination policy for an Amazon EMR cluster.getBlockPublicAccessConfiguration
(Consumer<GetBlockPublicAccessConfigurationRequest.Builder> getBlockPublicAccessConfigurationRequest) Returns the Amazon EMR block public access configuration for your Amazon Web Services account in the current Region.getBlockPublicAccessConfiguration
(GetBlockPublicAccessConfigurationRequest getBlockPublicAccessConfigurationRequest) Returns the Amazon EMR block public access configuration for your Amazon Web Services account in the current Region.getClusterSessionCredentials
(Consumer<GetClusterSessionCredentialsRequest.Builder> getClusterSessionCredentialsRequest) Provides temporary, HTTP basic credentials that are associated with a given runtime IAM role and used by a cluster with fine-grained access control activated.getClusterSessionCredentials
(GetClusterSessionCredentialsRequest getClusterSessionCredentialsRequest) Provides temporary, HTTP basic credentials that are associated with a given runtime IAM role and used by a cluster with fine-grained access control activated.default GetManagedScalingPolicyResponse
getManagedScalingPolicy
(Consumer<GetManagedScalingPolicyRequest.Builder> getManagedScalingPolicyRequest) Fetches the attached managed scaling policy for an Amazon EMR cluster.default GetManagedScalingPolicyResponse
getManagedScalingPolicy
(GetManagedScalingPolicyRequest getManagedScalingPolicyRequest) Fetches the attached managed scaling policy for an Amazon EMR cluster.default GetStudioSessionMappingResponse
getStudioSessionMapping
(Consumer<GetStudioSessionMappingRequest.Builder> getStudioSessionMappingRequest) Fetches mapping details for the specified Amazon EMR Studio and identity (user or group).default GetStudioSessionMappingResponse
getStudioSessionMapping
(GetStudioSessionMappingRequest getStudioSessionMappingRequest) Fetches mapping details for the specified Amazon EMR Studio and identity (user or group).default ListBootstrapActionsResponse
listBootstrapActions
(Consumer<ListBootstrapActionsRequest.Builder> listBootstrapActionsRequest) Provides information about the bootstrap actions associated with a cluster.default ListBootstrapActionsResponse
listBootstrapActions
(ListBootstrapActionsRequest listBootstrapActionsRequest) Provides information about the bootstrap actions associated with a cluster.default ListBootstrapActionsIterable
listBootstrapActionsPaginator
(Consumer<ListBootstrapActionsRequest.Builder> listBootstrapActionsRequest) This is a variant oflistBootstrapActions(software.amazon.awssdk.services.emr.model.ListBootstrapActionsRequest)
operation.default ListBootstrapActionsIterable
listBootstrapActionsPaginator
(ListBootstrapActionsRequest listBootstrapActionsRequest) This is a variant oflistBootstrapActions(software.amazon.awssdk.services.emr.model.ListBootstrapActionsRequest)
operation.default ListClustersResponse
Provides the status of all clusters visible to this Amazon Web Services account.default ListClustersResponse
listClusters
(Consumer<ListClustersRequest.Builder> listClustersRequest) Provides the status of all clusters visible to this Amazon Web Services account.default ListClustersResponse
listClusters
(ListClustersRequest listClustersRequest) Provides the status of all clusters visible to this Amazon Web Services account.default ListClustersIterable
This is a variant oflistClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
operation.default ListClustersIterable
listClustersPaginator
(Consumer<ListClustersRequest.Builder> listClustersRequest) This is a variant oflistClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
operation.default ListClustersIterable
listClustersPaginator
(ListClustersRequest listClustersRequest) This is a variant oflistClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
operation.default ListInstanceFleetsResponse
listInstanceFleets
(Consumer<ListInstanceFleetsRequest.Builder> listInstanceFleetsRequest) Lists all available details about the instance fleets in a cluster.default ListInstanceFleetsResponse
listInstanceFleets
(ListInstanceFleetsRequest listInstanceFleetsRequest) Lists all available details about the instance fleets in a cluster.default ListInstanceFleetsIterable
listInstanceFleetsPaginator
(Consumer<ListInstanceFleetsRequest.Builder> listInstanceFleetsRequest) This is a variant oflistInstanceFleets(software.amazon.awssdk.services.emr.model.ListInstanceFleetsRequest)
operation.default ListInstanceFleetsIterable
listInstanceFleetsPaginator
(ListInstanceFleetsRequest listInstanceFleetsRequest) This is a variant oflistInstanceFleets(software.amazon.awssdk.services.emr.model.ListInstanceFleetsRequest)
operation.default ListInstanceGroupsResponse
listInstanceGroups
(Consumer<ListInstanceGroupsRequest.Builder> listInstanceGroupsRequest) Provides all available details about the instance groups in a cluster.default ListInstanceGroupsResponse
listInstanceGroups
(ListInstanceGroupsRequest listInstanceGroupsRequest) Provides all available details about the instance groups in a cluster.default ListInstanceGroupsIterable
listInstanceGroupsPaginator
(Consumer<ListInstanceGroupsRequest.Builder> listInstanceGroupsRequest) This is a variant oflistInstanceGroups(software.amazon.awssdk.services.emr.model.ListInstanceGroupsRequest)
operation.default ListInstanceGroupsIterable
listInstanceGroupsPaginator
(ListInstanceGroupsRequest listInstanceGroupsRequest) This is a variant oflistInstanceGroups(software.amazon.awssdk.services.emr.model.ListInstanceGroupsRequest)
operation.default ListInstancesResponse
listInstances
(Consumer<ListInstancesRequest.Builder> listInstancesRequest) Provides information for all active Amazon EC2 instances and Amazon EC2 instances terminated in the last 30 days, up to a maximum of 2,000.default ListInstancesResponse
listInstances
(ListInstancesRequest listInstancesRequest) Provides information for all active Amazon EC2 instances and Amazon EC2 instances terminated in the last 30 days, up to a maximum of 2,000.default ListInstancesIterable
listInstancesPaginator
(Consumer<ListInstancesRequest.Builder> listInstancesRequest) This is a variant oflistInstances(software.amazon.awssdk.services.emr.model.ListInstancesRequest)
operation.default ListInstancesIterable
listInstancesPaginator
(ListInstancesRequest listInstancesRequest) This is a variant oflistInstances(software.amazon.awssdk.services.emr.model.ListInstancesRequest)
operation.default ListNotebookExecutionsResponse
listNotebookExecutions
(Consumer<ListNotebookExecutionsRequest.Builder> listNotebookExecutionsRequest) Provides summaries of all notebook executions.default ListNotebookExecutionsResponse
listNotebookExecutions
(ListNotebookExecutionsRequest listNotebookExecutionsRequest) Provides summaries of all notebook executions.default ListNotebookExecutionsIterable
listNotebookExecutionsPaginator
(Consumer<ListNotebookExecutionsRequest.Builder> listNotebookExecutionsRequest) This is a variant oflistNotebookExecutions(software.amazon.awssdk.services.emr.model.ListNotebookExecutionsRequest)
operation.default ListNotebookExecutionsIterable
listNotebookExecutionsPaginator
(ListNotebookExecutionsRequest listNotebookExecutionsRequest) This is a variant oflistNotebookExecutions(software.amazon.awssdk.services.emr.model.ListNotebookExecutionsRequest)
operation.default ListReleaseLabelsResponse
listReleaseLabels
(Consumer<ListReleaseLabelsRequest.Builder> listReleaseLabelsRequest) Retrieves release labels of Amazon EMR services in the Region where the API is called.default ListReleaseLabelsResponse
listReleaseLabels
(ListReleaseLabelsRequest listReleaseLabelsRequest) Retrieves release labels of Amazon EMR services in the Region where the API is called.default ListReleaseLabelsIterable
listReleaseLabelsPaginator
(Consumer<ListReleaseLabelsRequest.Builder> listReleaseLabelsRequest) This is a variant oflistReleaseLabels(software.amazon.awssdk.services.emr.model.ListReleaseLabelsRequest)
operation.default ListReleaseLabelsIterable
listReleaseLabelsPaginator
(ListReleaseLabelsRequest listReleaseLabelsRequest) This is a variant oflistReleaseLabels(software.amazon.awssdk.services.emr.model.ListReleaseLabelsRequest)
operation.Lists all the security configurations visible to this account, providing their creation dates and times, and their names.listSecurityConfigurations
(Consumer<ListSecurityConfigurationsRequest.Builder> listSecurityConfigurationsRequest) Lists all the security configurations visible to this account, providing their creation dates and times, and their names.listSecurityConfigurations
(ListSecurityConfigurationsRequest listSecurityConfigurationsRequest) Lists all the security configurations visible to this account, providing their creation dates and times, and their names.This is a variant oflistSecurityConfigurations(software.amazon.awssdk.services.emr.model.ListSecurityConfigurationsRequest)
operation.listSecurityConfigurationsPaginator
(Consumer<ListSecurityConfigurationsRequest.Builder> listSecurityConfigurationsRequest) This is a variant oflistSecurityConfigurations(software.amazon.awssdk.services.emr.model.ListSecurityConfigurationsRequest)
operation.listSecurityConfigurationsPaginator
(ListSecurityConfigurationsRequest listSecurityConfigurationsRequest) This is a variant oflistSecurityConfigurations(software.amazon.awssdk.services.emr.model.ListSecurityConfigurationsRequest)
operation.default ListStepsResponse
listSteps
(Consumer<ListStepsRequest.Builder> listStepsRequest) Provides a list of steps for the cluster in reverse order unless you specifystepIds
with the request or filter byStepStates
.default ListStepsResponse
listSteps
(ListStepsRequest listStepsRequest) Provides a list of steps for the cluster in reverse order unless you specifystepIds
with the request or filter byStepStates
.default ListStepsIterable
listStepsPaginator
(Consumer<ListStepsRequest.Builder> listStepsRequest) This is a variant oflistSteps(software.amazon.awssdk.services.emr.model.ListStepsRequest)
operation.default ListStepsIterable
listStepsPaginator
(ListStepsRequest listStepsRequest) This is a variant oflistSteps(software.amazon.awssdk.services.emr.model.ListStepsRequest)
operation.default ListStudiosResponse
listStudios
(Consumer<ListStudiosRequest.Builder> listStudiosRequest) Returns a list of all Amazon EMR Studios associated with the Amazon Web Services account.default ListStudiosResponse
listStudios
(ListStudiosRequest listStudiosRequest) Returns a list of all Amazon EMR Studios associated with the Amazon Web Services account.listStudioSessionMappings
(Consumer<ListStudioSessionMappingsRequest.Builder> listStudioSessionMappingsRequest) Returns a list of all user or group session mappings for the Amazon EMR Studio specified byStudioId
.listStudioSessionMappings
(ListStudioSessionMappingsRequest listStudioSessionMappingsRequest) Returns a list of all user or group session mappings for the Amazon EMR Studio specified byStudioId
.listStudioSessionMappingsPaginator
(Consumer<ListStudioSessionMappingsRequest.Builder> listStudioSessionMappingsRequest) This is a variant oflistStudioSessionMappings(software.amazon.awssdk.services.emr.model.ListStudioSessionMappingsRequest)
operation.listStudioSessionMappingsPaginator
(ListStudioSessionMappingsRequest listStudioSessionMappingsRequest) This is a variant oflistStudioSessionMappings(software.amazon.awssdk.services.emr.model.ListStudioSessionMappingsRequest)
operation.default ListStudiosIterable
listStudiosPaginator
(Consumer<ListStudiosRequest.Builder> listStudiosRequest) This is a variant oflistStudios(software.amazon.awssdk.services.emr.model.ListStudiosRequest)
operation.default ListStudiosIterable
listStudiosPaginator
(ListStudiosRequest listStudiosRequest) This is a variant oflistStudios(software.amazon.awssdk.services.emr.model.ListStudiosRequest)
operation.listSupportedInstanceTypes
(Consumer<ListSupportedInstanceTypesRequest.Builder> listSupportedInstanceTypesRequest) A list of the instance types that Amazon EMR supports.listSupportedInstanceTypes
(ListSupportedInstanceTypesRequest listSupportedInstanceTypesRequest) A list of the instance types that Amazon EMR supports.listSupportedInstanceTypesPaginator
(Consumer<ListSupportedInstanceTypesRequest.Builder> listSupportedInstanceTypesRequest) This is a variant oflistSupportedInstanceTypes(software.amazon.awssdk.services.emr.model.ListSupportedInstanceTypesRequest)
operation.listSupportedInstanceTypesPaginator
(ListSupportedInstanceTypesRequest listSupportedInstanceTypesRequest) This is a variant oflistSupportedInstanceTypes(software.amazon.awssdk.services.emr.model.ListSupportedInstanceTypesRequest)
operation.default ModifyClusterResponse
modifyCluster
(Consumer<ModifyClusterRequest.Builder> modifyClusterRequest) Modifies the number of steps that can be executed concurrently for the cluster specified using ClusterID.default ModifyClusterResponse
modifyCluster
(ModifyClusterRequest modifyClusterRequest) Modifies the number of steps that can be executed concurrently for the cluster specified using ClusterID.default ModifyInstanceFleetResponse
modifyInstanceFleet
(Consumer<ModifyInstanceFleetRequest.Builder> modifyInstanceFleetRequest) Modifies the target On-Demand and target Spot capacities for the instance fleet with the specified InstanceFleetID within the cluster specified using ClusterID.default ModifyInstanceFleetResponse
modifyInstanceFleet
(ModifyInstanceFleetRequest modifyInstanceFleetRequest) Modifies the target On-Demand and target Spot capacities for the instance fleet with the specified InstanceFleetID within the cluster specified using ClusterID.default ModifyInstanceGroupsResponse
modifyInstanceGroups
(Consumer<ModifyInstanceGroupsRequest.Builder> modifyInstanceGroupsRequest) ModifyInstanceGroups modifies the number of nodes and configuration settings of an instance group.default ModifyInstanceGroupsResponse
modifyInstanceGroups
(ModifyInstanceGroupsRequest modifyInstanceGroupsRequest) ModifyInstanceGroups modifies the number of nodes and configuration settings of an instance group.default PutAutoScalingPolicyResponse
putAutoScalingPolicy
(Consumer<PutAutoScalingPolicyRequest.Builder> putAutoScalingPolicyRequest) Creates or updates an automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster.default PutAutoScalingPolicyResponse
putAutoScalingPolicy
(PutAutoScalingPolicyRequest putAutoScalingPolicyRequest) Creates or updates an automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster.default PutAutoTerminationPolicyResponse
putAutoTerminationPolicy
(Consumer<PutAutoTerminationPolicyRequest.Builder> putAutoTerminationPolicyRequest) default PutAutoTerminationPolicyResponse
putAutoTerminationPolicy
(PutAutoTerminationPolicyRequest putAutoTerminationPolicyRequest) putBlockPublicAccessConfiguration
(Consumer<PutBlockPublicAccessConfigurationRequest.Builder> putBlockPublicAccessConfigurationRequest) Creates or updates an Amazon EMR block public access configuration for your Amazon Web Services account in the current Region.putBlockPublicAccessConfiguration
(PutBlockPublicAccessConfigurationRequest putBlockPublicAccessConfigurationRequest) Creates or updates an Amazon EMR block public access configuration for your Amazon Web Services account in the current Region.default PutManagedScalingPolicyResponse
putManagedScalingPolicy
(Consumer<PutManagedScalingPolicyRequest.Builder> putManagedScalingPolicyRequest) Creates or updates a managed scaling policy for an Amazon EMR cluster.default PutManagedScalingPolicyResponse
putManagedScalingPolicy
(PutManagedScalingPolicyRequest putManagedScalingPolicyRequest) Creates or updates a managed scaling policy for an Amazon EMR cluster.default RemoveAutoScalingPolicyResponse
removeAutoScalingPolicy
(Consumer<RemoveAutoScalingPolicyRequest.Builder> removeAutoScalingPolicyRequest) Removes an automatic scaling policy from a specified instance group within an Amazon EMR cluster.default RemoveAutoScalingPolicyResponse
removeAutoScalingPolicy
(RemoveAutoScalingPolicyRequest removeAutoScalingPolicyRequest) Removes an automatic scaling policy from a specified instance group within an Amazon EMR cluster.removeAutoTerminationPolicy
(Consumer<RemoveAutoTerminationPolicyRequest.Builder> removeAutoTerminationPolicyRequest) Removes an auto-termination policy from an Amazon EMR cluster.removeAutoTerminationPolicy
(RemoveAutoTerminationPolicyRequest removeAutoTerminationPolicyRequest) Removes an auto-termination policy from an Amazon EMR cluster.removeManagedScalingPolicy
(Consumer<RemoveManagedScalingPolicyRequest.Builder> removeManagedScalingPolicyRequest) Removes a managed scaling policy from a specified Amazon EMR cluster.removeManagedScalingPolicy
(RemoveManagedScalingPolicyRequest removeManagedScalingPolicyRequest) Removes a managed scaling policy from a specified Amazon EMR cluster.default RemoveTagsResponse
removeTags
(Consumer<RemoveTagsRequest.Builder> removeTagsRequest) Removes tags from an Amazon EMR resource, such as a cluster or Amazon EMR Studio.default RemoveTagsResponse
removeTags
(RemoveTagsRequest removeTagsRequest) Removes tags from an Amazon EMR resource, such as a cluster or Amazon EMR Studio.default RunJobFlowResponse
runJobFlow
(Consumer<RunJobFlowRequest.Builder> runJobFlowRequest) RunJobFlow creates and starts running a new cluster (job flow).default RunJobFlowResponse
runJobFlow
(RunJobFlowRequest runJobFlowRequest) RunJobFlow creates and starts running a new cluster (job flow).default EmrServiceClientConfiguration
The SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfigurationstatic ServiceMetadata
setKeepJobFlowAliveWhenNoSteps
(Consumer<SetKeepJobFlowAliveWhenNoStepsRequest.Builder> setKeepJobFlowAliveWhenNoStepsRequest) You can use theSetKeepJobFlowAliveWhenNoSteps
to configure a cluster (job flow) to terminate after the step execution, i.e., all your steps are executed.setKeepJobFlowAliveWhenNoSteps
(SetKeepJobFlowAliveWhenNoStepsRequest setKeepJobFlowAliveWhenNoStepsRequest) You can use theSetKeepJobFlowAliveWhenNoSteps
to configure a cluster (job flow) to terminate after the step execution, i.e., all your steps are executed.default SetTerminationProtectionResponse
setTerminationProtection
(Consumer<SetTerminationProtectionRequest.Builder> setTerminationProtectionRequest) SetTerminationProtection locks a cluster (job flow) so the Amazon EC2 instances in the cluster cannot be terminated by user intervention, an API call, or in the event of a job-flow error.default SetTerminationProtectionResponse
setTerminationProtection
(SetTerminationProtectionRequest setTerminationProtectionRequest) SetTerminationProtection locks a cluster (job flow) so the Amazon EC2 instances in the cluster cannot be terminated by user intervention, an API call, or in the event of a job-flow error.setUnhealthyNodeReplacement
(Consumer<SetUnhealthyNodeReplacementRequest.Builder> setUnhealthyNodeReplacementRequest) Specify whether to enable unhealthy node replacement, which lets Amazon EMR gracefully replace core nodes on a cluster if any nodes become unhealthy.setUnhealthyNodeReplacement
(SetUnhealthyNodeReplacementRequest setUnhealthyNodeReplacementRequest) Specify whether to enable unhealthy node replacement, which lets Amazon EMR gracefully replace core nodes on a cluster if any nodes become unhealthy.default SetVisibleToAllUsersResponse
setVisibleToAllUsers
(Consumer<SetVisibleToAllUsersRequest.Builder> setVisibleToAllUsersRequest) default SetVisibleToAllUsersResponse
setVisibleToAllUsers
(SetVisibleToAllUsersRequest setVisibleToAllUsersRequest) default StartNotebookExecutionResponse
startNotebookExecution
(Consumer<StartNotebookExecutionRequest.Builder> startNotebookExecutionRequest) Starts a notebook execution.default StartNotebookExecutionResponse
startNotebookExecution
(StartNotebookExecutionRequest startNotebookExecutionRequest) Starts a notebook execution.default StopNotebookExecutionResponse
stopNotebookExecution
(Consumer<StopNotebookExecutionRequest.Builder> stopNotebookExecutionRequest) Stops a notebook execution.default StopNotebookExecutionResponse
stopNotebookExecution
(StopNotebookExecutionRequest stopNotebookExecutionRequest) Stops a notebook execution.default TerminateJobFlowsResponse
terminateJobFlows
(Consumer<TerminateJobFlowsRequest.Builder> terminateJobFlowsRequest) TerminateJobFlows shuts a list of clusters (job flows) down.default TerminateJobFlowsResponse
terminateJobFlows
(TerminateJobFlowsRequest terminateJobFlowsRequest) TerminateJobFlows shuts a list of clusters (job flows) down.default UpdateStudioResponse
updateStudio
(Consumer<UpdateStudioRequest.Builder> updateStudioRequest) Updates an Amazon EMR Studio configuration, including attributes such as name, description, and subnets.default UpdateStudioResponse
updateStudio
(UpdateStudioRequest updateStudioRequest) Updates an Amazon EMR Studio configuration, including attributes such as name, description, and subnets.updateStudioSessionMapping
(Consumer<UpdateStudioSessionMappingRequest.Builder> updateStudioSessionMappingRequest) Updates the session policy attached to the user or group for the specified Amazon EMR Studio.updateStudioSessionMapping
(UpdateStudioSessionMappingRequest updateStudioSessionMappingRequest) Updates the session policy attached to the user or group for the specified Amazon EMR Studio.default EmrWaiter
waiter()
Create an instance ofEmrWaiter
using this client.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
-
addInstanceFleet
default AddInstanceFleetResponse addInstanceFleet(AddInstanceFleetRequest addInstanceFleetRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Adds an instance fleet to a running cluster.
The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x.
- Parameters:
addInstanceFleetRequest
-- Returns:
- Result of the AddInstanceFleet operation returned by the service.
- See Also:
-
addInstanceFleet
default AddInstanceFleetResponse addInstanceFleet(Consumer<AddInstanceFleetRequest.Builder> addInstanceFleetRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Adds an instance fleet to a running cluster.
The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x.
This is a convenience which creates an instance of the
AddInstanceFleetRequest.Builder
avoiding the need to create one manually viaAddInstanceFleetRequest.builder()
- Parameters:
addInstanceFleetRequest
- AConsumer
that will call methods onAddInstanceFleetRequest.Builder
to create a request.- Returns:
- Result of the AddInstanceFleet operation returned by the service.
- See Also:
-
addInstanceGroups
default AddInstanceGroupsResponse addInstanceGroups(AddInstanceGroupsRequest addInstanceGroupsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException Adds one or more instance groups to a running cluster.
- Parameters:
addInstanceGroupsRequest
- Input to an AddInstanceGroups call.- Returns:
- Result of the AddInstanceGroups operation returned by the service.
- See Also:
-
addInstanceGroups
default AddInstanceGroupsResponse addInstanceGroups(Consumer<AddInstanceGroupsRequest.Builder> addInstanceGroupsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException Adds one or more instance groups to a running cluster.
This is a convenience which creates an instance of the
AddInstanceGroupsRequest.Builder
avoiding the need to create one manually viaAddInstanceGroupsRequest.builder()
- Parameters:
addInstanceGroupsRequest
- AConsumer
that will call methods onAddInstanceGroupsRequest.Builder
to create a request. Input to an AddInstanceGroups call.- Returns:
- Result of the AddInstanceGroups operation returned by the service.
- See Also:
-
addJobFlowSteps
default AddJobFlowStepsResponse addJobFlowSteps(AddJobFlowStepsRequest addJobFlowStepsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException AddJobFlowSteps adds new steps to a running cluster. A maximum of 256 steps are allowed in each job flow.
If your cluster is long-running (such as a Hive data warehouse) or complex, you may require more than 256 steps to process your data. You can bypass the 256-step limitation in various ways, including using SSH to connect to the master node and submitting queries directly to the software running on the master node, such as Hive and Hadoop.
A step specifies the location of a JAR file stored either on the master node of the cluster or in Amazon S3. Each step is performed by the main function of the main class of the JAR file. The main class can be specified either in the manifest of the JAR or by using the MainFunction parameter of the step.
Amazon EMR executes each step in the order listed. For a step to be considered complete, the main function must exit with a zero exit code and all Hadoop jobs started while the step was running must have completed and run successfully.
You can only add steps to a cluster that is in one of the following states: STARTING, BOOTSTRAPPING, RUNNING, or WAITING.
The string values passed into
HadoopJarStep
object cannot exceed a total of 10240 characters.- Parameters:
addJobFlowStepsRequest
- The input argument to the AddJobFlowSteps operation.- Returns:
- Result of the AddJobFlowSteps operation returned by the service.
- See Also:
-
addJobFlowSteps
default AddJobFlowStepsResponse addJobFlowSteps(Consumer<AddJobFlowStepsRequest.Builder> addJobFlowStepsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException AddJobFlowSteps adds new steps to a running cluster. A maximum of 256 steps are allowed in each job flow.
If your cluster is long-running (such as a Hive data warehouse) or complex, you may require more than 256 steps to process your data. You can bypass the 256-step limitation in various ways, including using SSH to connect to the master node and submitting queries directly to the software running on the master node, such as Hive and Hadoop.
A step specifies the location of a JAR file stored either on the master node of the cluster or in Amazon S3. Each step is performed by the main function of the main class of the JAR file. The main class can be specified either in the manifest of the JAR or by using the MainFunction parameter of the step.
Amazon EMR executes each step in the order listed. For a step to be considered complete, the main function must exit with a zero exit code and all Hadoop jobs started while the step was running must have completed and run successfully.
You can only add steps to a cluster that is in one of the following states: STARTING, BOOTSTRAPPING, RUNNING, or WAITING.
The string values passed into
HadoopJarStep
object cannot exceed a total of 10240 characters.
This is a convenience which creates an instance of the
AddJobFlowStepsRequest.Builder
avoiding the need to create one manually viaAddJobFlowStepsRequest.builder()
- Parameters:
addJobFlowStepsRequest
- AConsumer
that will call methods onAddJobFlowStepsRequest.Builder
to create a request. The input argument to the AddJobFlowSteps operation.- Returns:
- Result of the AddJobFlowSteps operation returned by the service.
- See Also:
-
addTags
default AddTagsResponse addTags(AddTagsRequest addTagsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Adds tags to an Amazon EMR resource, such as a cluster or an Amazon EMR Studio. Tags make it easier to associate resources in various ways, such as grouping clusters to track your Amazon EMR resource allocation costs. For more information, see Tag Clusters.
- Parameters:
addTagsRequest
- This input identifies an Amazon EMR resource and a list of tags to attach.- Returns:
- Result of the AddTags operation returned by the service.
- See Also:
-
addTags
default AddTagsResponse addTags(Consumer<AddTagsRequest.Builder> addTagsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Adds tags to an Amazon EMR resource, such as a cluster or an Amazon EMR Studio. Tags make it easier to associate resources in various ways, such as grouping clusters to track your Amazon EMR resource allocation costs. For more information, see Tag Clusters.
This is a convenience which creates an instance of the
AddTagsRequest.Builder
avoiding the need to create one manually viaAddTagsRequest.builder()
- Parameters:
addTagsRequest
- AConsumer
that will call methods onAddTagsRequest.Builder
to create a request. This input identifies an Amazon EMR resource and a list of tags to attach.- Returns:
- Result of the AddTags operation returned by the service.
- See Also:
-
cancelSteps
default CancelStepsResponse cancelSteps(CancelStepsRequest cancelStepsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Cancels a pending step or steps in a running cluster. Available only in Amazon EMR versions 4.8.0 and later, excluding version 5.0.0. A maximum of 256 steps are allowed in each CancelSteps request. CancelSteps is idempotent but asynchronous; it does not guarantee that a step will be canceled, even if the request is successfully submitted. When you use Amazon EMR releases 5.28.0 and later, you can cancel steps that are in a
PENDING
orRUNNING
state. In earlier versions of Amazon EMR, you can only cancel steps that are in aPENDING
state.- Parameters:
cancelStepsRequest
- The input argument to the CancelSteps operation.- Returns:
- Result of the CancelSteps operation returned by the service.
- See Also:
-
cancelSteps
default CancelStepsResponse cancelSteps(Consumer<CancelStepsRequest.Builder> cancelStepsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Cancels a pending step or steps in a running cluster. Available only in Amazon EMR versions 4.8.0 and later, excluding version 5.0.0. A maximum of 256 steps are allowed in each CancelSteps request. CancelSteps is idempotent but asynchronous; it does not guarantee that a step will be canceled, even if the request is successfully submitted. When you use Amazon EMR releases 5.28.0 and later, you can cancel steps that are in a
PENDING
orRUNNING
state. In earlier versions of Amazon EMR, you can only cancel steps that are in aPENDING
state.
This is a convenience which creates an instance of the
CancelStepsRequest.Builder
avoiding the need to create one manually viaCancelStepsRequest.builder()
- Parameters:
cancelStepsRequest
- AConsumer
that will call methods onCancelStepsRequest.Builder
to create a request. The input argument to the CancelSteps operation.- Returns:
- Result of the CancelSteps operation returned by the service.
- See Also:
-
createSecurityConfiguration
default CreateSecurityConfigurationResponse createSecurityConfiguration(CreateSecurityConfigurationRequest createSecurityConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Creates a security configuration, which is stored in the service and can be specified when a cluster is created.
- Parameters:
createSecurityConfigurationRequest
-- Returns:
- Result of the CreateSecurityConfiguration operation returned by the service.
- See Also:
-
createSecurityConfiguration
default CreateSecurityConfigurationResponse createSecurityConfiguration(Consumer<CreateSecurityConfigurationRequest.Builder> createSecurityConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Creates a security configuration, which is stored in the service and can be specified when a cluster is created.
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:
-
createStudio
default CreateStudioResponse createStudio(CreateStudioRequest createStudioRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Creates a new Amazon EMR Studio.
- Parameters:
createStudioRequest
-- Returns:
- Result of the CreateStudio operation returned by the service.
- See Also:
-
createStudio
default CreateStudioResponse createStudio(Consumer<CreateStudioRequest.Builder> createStudioRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Creates a new Amazon EMR Studio.
This is a convenience which creates an instance of the
CreateStudioRequest.Builder
avoiding the need to create one manually viaCreateStudioRequest.builder()
- Parameters:
createStudioRequest
- AConsumer
that will call methods onCreateStudioRequest.Builder
to create a request.- Returns:
- Result of the CreateStudio operation returned by the service.
- See Also:
-
createStudioSessionMapping
default CreateStudioSessionMappingResponse createStudioSessionMapping(CreateStudioSessionMappingRequest createStudioSessionMappingRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Maps a user or group to the Amazon EMR Studio specified by
StudioId
, and applies a session policy to refine Studio permissions for that user or group. UseCreateStudioSessionMapping
to assign users to a Studio when you use IAM Identity Center authentication. For instructions on how to assign users to a Studio when you use IAM authentication, see Assign a user or group to your EMR Studio.- Parameters:
createStudioSessionMappingRequest
-- Returns:
- Result of the CreateStudioSessionMapping operation returned by the service.
- See Also:
-
createStudioSessionMapping
default CreateStudioSessionMappingResponse createStudioSessionMapping(Consumer<CreateStudioSessionMappingRequest.Builder> createStudioSessionMappingRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Maps a user or group to the Amazon EMR Studio specified by
StudioId
, and applies a session policy to refine Studio permissions for that user or group. UseCreateStudioSessionMapping
to assign users to a Studio when you use IAM Identity Center authentication. For instructions on how to assign users to a Studio when you use IAM authentication, see Assign a user or group to your EMR Studio.
This is a convenience which creates an instance of the
CreateStudioSessionMappingRequest.Builder
avoiding the need to create one manually viaCreateStudioSessionMappingRequest.builder()
- Parameters:
createStudioSessionMappingRequest
- AConsumer
that will call methods onCreateStudioSessionMappingRequest.Builder
to create a request.- Returns:
- Result of the CreateStudioSessionMapping operation returned by the service.
- See Also:
-
deleteSecurityConfiguration
default DeleteSecurityConfigurationResponse deleteSecurityConfiguration(DeleteSecurityConfigurationRequest deleteSecurityConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Deletes a security configuration.
- Parameters:
deleteSecurityConfigurationRequest
-- Returns:
- Result of the DeleteSecurityConfiguration operation returned by the service.
- See Also:
-
deleteSecurityConfiguration
default DeleteSecurityConfigurationResponse deleteSecurityConfiguration(Consumer<DeleteSecurityConfigurationRequest.Builder> deleteSecurityConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Deletes a security configuration.
This is a convenience which creates an instance of the
DeleteSecurityConfigurationRequest.Builder
avoiding the need to create one manually viaDeleteSecurityConfigurationRequest.builder()
- Parameters:
deleteSecurityConfigurationRequest
- AConsumer
that will call methods onDeleteSecurityConfigurationRequest.Builder
to create a request.- Returns:
- Result of the DeleteSecurityConfiguration operation returned by the service.
- See Also:
-
deleteStudio
default DeleteStudioResponse deleteStudio(DeleteStudioRequest deleteStudioRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Removes an Amazon EMR Studio from the Studio metadata store.
- Parameters:
deleteStudioRequest
-- Returns:
- Result of the DeleteStudio operation returned by the service.
- See Also:
-
deleteStudio
default DeleteStudioResponse deleteStudio(Consumer<DeleteStudioRequest.Builder> deleteStudioRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Removes an Amazon EMR Studio from the Studio metadata store.
This is a convenience which creates an instance of the
DeleteStudioRequest.Builder
avoiding the need to create one manually viaDeleteStudioRequest.builder()
- Parameters:
deleteStudioRequest
- AConsumer
that will call methods onDeleteStudioRequest.Builder
to create a request.- Returns:
- Result of the DeleteStudio operation returned by the service.
- See Also:
-
deleteStudioSessionMapping
default DeleteStudioSessionMappingResponse deleteStudioSessionMapping(DeleteStudioSessionMappingRequest deleteStudioSessionMappingRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Removes a user or group from an Amazon EMR Studio.
- Parameters:
deleteStudioSessionMappingRequest
-- Returns:
- Result of the DeleteStudioSessionMapping operation returned by the service.
- See Also:
-
deleteStudioSessionMapping
default DeleteStudioSessionMappingResponse deleteStudioSessionMapping(Consumer<DeleteStudioSessionMappingRequest.Builder> deleteStudioSessionMappingRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Removes a user or group from an Amazon EMR Studio.
This is a convenience which creates an instance of the
DeleteStudioSessionMappingRequest.Builder
avoiding the need to create one manually viaDeleteStudioSessionMappingRequest.builder()
- Parameters:
deleteStudioSessionMappingRequest
- AConsumer
that will call methods onDeleteStudioSessionMappingRequest.Builder
to create a request.- Returns:
- Result of the DeleteStudioSessionMapping operation returned by the service.
- See Also:
-
describeCluster
default DescribeClusterResponse describeCluster(DescribeClusterRequest describeClusterRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides cluster-level details including status, hardware and software configuration, VPC settings, and so on.
- Parameters:
describeClusterRequest
- This input determines which cluster to describe.- Returns:
- Result of the DescribeCluster operation returned by the service.
- See Also:
-
describeCluster
default DescribeClusterResponse describeCluster(Consumer<DescribeClusterRequest.Builder> describeClusterRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides cluster-level details including status, hardware and software configuration, VPC settings, and so on.
This is a convenience which creates an instance of the
DescribeClusterRequest.Builder
avoiding the need to create one manually viaDescribeClusterRequest.builder()
- Parameters:
describeClusterRequest
- AConsumer
that will call methods onDescribeClusterRequest.Builder
to create a request. This input determines which cluster to describe.- Returns:
- Result of the DescribeCluster operation returned by the service.
- See Also:
-
describeNotebookExecution
default DescribeNotebookExecutionResponse describeNotebookExecution(DescribeNotebookExecutionRequest describeNotebookExecutionRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides details of a notebook execution.
- Parameters:
describeNotebookExecutionRequest
-- Returns:
- Result of the DescribeNotebookExecution operation returned by the service.
- See Also:
-
describeNotebookExecution
default DescribeNotebookExecutionResponse describeNotebookExecution(Consumer<DescribeNotebookExecutionRequest.Builder> describeNotebookExecutionRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides details of a notebook execution.
This is a convenience which creates an instance of the
DescribeNotebookExecutionRequest.Builder
avoiding the need to create one manually viaDescribeNotebookExecutionRequest.builder()
- Parameters:
describeNotebookExecutionRequest
- AConsumer
that will call methods onDescribeNotebookExecutionRequest.Builder
to create a request.- Returns:
- Result of the DescribeNotebookExecution operation returned by the service.
- See Also:
-
describeReleaseLabel
default DescribeReleaseLabelResponse describeReleaseLabel(DescribeReleaseLabelRequest describeReleaseLabelRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides Amazon EMR release label details, such as the releases available the Region where the API request is run, and the available applications for a specific Amazon EMR release label. Can also list Amazon EMR releases that support a specified version of Spark.
- Parameters:
describeReleaseLabelRequest
-- Returns:
- Result of the DescribeReleaseLabel operation returned by the service.
- See Also:
-
describeReleaseLabel
default DescribeReleaseLabelResponse describeReleaseLabel(Consumer<DescribeReleaseLabelRequest.Builder> describeReleaseLabelRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides Amazon EMR release label details, such as the releases available the Region where the API request is run, and the available applications for a specific Amazon EMR release label. Can also list Amazon EMR releases that support a specified version of Spark.
This is a convenience which creates an instance of the
DescribeReleaseLabelRequest.Builder
avoiding the need to create one manually viaDescribeReleaseLabelRequest.builder()
- Parameters:
describeReleaseLabelRequest
- AConsumer
that will call methods onDescribeReleaseLabelRequest.Builder
to create a request.- Returns:
- Result of the DescribeReleaseLabel operation returned by the service.
- See Also:
-
describeSecurityConfiguration
default DescribeSecurityConfigurationResponse describeSecurityConfiguration(DescribeSecurityConfigurationRequest describeSecurityConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides the details of a security configuration by returning the configuration JSON.
- Parameters:
describeSecurityConfigurationRequest
-- Returns:
- Result of the DescribeSecurityConfiguration operation returned by the service.
- See Also:
-
describeSecurityConfiguration
default DescribeSecurityConfigurationResponse describeSecurityConfiguration(Consumer<DescribeSecurityConfigurationRequest.Builder> describeSecurityConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides the details of a security configuration by returning the configuration JSON.
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:
-
describeStep
default DescribeStepResponse describeStep(DescribeStepRequest describeStepRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides more detail about the cluster step.
- Parameters:
describeStepRequest
- This input determines which step to describe.- Returns:
- Result of the DescribeStep operation returned by the service.
- See Also:
-
describeStep
default DescribeStepResponse describeStep(Consumer<DescribeStepRequest.Builder> describeStepRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides more detail about the cluster step.
This is a convenience which creates an instance of the
DescribeStepRequest.Builder
avoiding the need to create one manually viaDescribeStepRequest.builder()
- Parameters:
describeStepRequest
- AConsumer
that will call methods onDescribeStepRequest.Builder
to create a request. This input determines which step to describe.- Returns:
- Result of the DescribeStep operation returned by the service.
- See Also:
-
describeStudio
default DescribeStudioResponse describeStudio(DescribeStudioRequest describeStudioRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio access URL, and so on.
- Parameters:
describeStudioRequest
-- Returns:
- Result of the DescribeStudio operation returned by the service.
- See Also:
-
describeStudio
default DescribeStudioResponse describeStudio(Consumer<DescribeStudioRequest.Builder> describeStudioRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio access URL, and so on.
This is a convenience which creates an instance of the
DescribeStudioRequest.Builder
avoiding the need to create one manually viaDescribeStudioRequest.builder()
- Parameters:
describeStudioRequest
- AConsumer
that will call methods onDescribeStudioRequest.Builder
to create a request.- Returns:
- Result of the DescribeStudio operation returned by the service.
- See Also:
-
getAutoTerminationPolicy
default GetAutoTerminationPolicyResponse getAutoTerminationPolicy(GetAutoTerminationPolicyRequest getAutoTerminationPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Returns the auto-termination policy for an Amazon EMR cluster.
- Parameters:
getAutoTerminationPolicyRequest
-- Returns:
- Result of the GetAutoTerminationPolicy operation returned by the service.
- See Also:
-
getAutoTerminationPolicy
default GetAutoTerminationPolicyResponse getAutoTerminationPolicy(Consumer<GetAutoTerminationPolicyRequest.Builder> getAutoTerminationPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Returns the auto-termination policy for an Amazon EMR cluster.
This is a convenience which creates an instance of the
GetAutoTerminationPolicyRequest.Builder
avoiding the need to create one manually viaGetAutoTerminationPolicyRequest.builder()
- Parameters:
getAutoTerminationPolicyRequest
- AConsumer
that will call methods onGetAutoTerminationPolicyRequest.Builder
to create a request.- Returns:
- Result of the GetAutoTerminationPolicy operation returned by the service.
- See Also:
-
getBlockPublicAccessConfiguration
default GetBlockPublicAccessConfigurationResponse getBlockPublicAccessConfiguration(GetBlockPublicAccessConfigurationRequest getBlockPublicAccessConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Returns the Amazon EMR block public access configuration for your Amazon Web Services account in the current Region. For more information see Configure Block Public Access for Amazon EMR in the Amazon EMR Management Guide.
- Parameters:
getBlockPublicAccessConfigurationRequest
-- Returns:
- Result of the GetBlockPublicAccessConfiguration operation returned by the service.
- See Also:
-
getBlockPublicAccessConfiguration
default GetBlockPublicAccessConfigurationResponse getBlockPublicAccessConfiguration(Consumer<GetBlockPublicAccessConfigurationRequest.Builder> getBlockPublicAccessConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Returns the Amazon EMR block public access configuration for your Amazon Web Services account in the current Region. For more information see Configure Block Public Access for Amazon EMR in the Amazon EMR Management Guide.
This is a convenience which creates an instance of the
GetBlockPublicAccessConfigurationRequest.Builder
avoiding the need to create one manually viaGetBlockPublicAccessConfigurationRequest.builder()
- Parameters:
getBlockPublicAccessConfigurationRequest
- AConsumer
that will call methods onGetBlockPublicAccessConfigurationRequest.Builder
to create a request.- Returns:
- Result of the GetBlockPublicAccessConfiguration operation returned by the service.
- See Also:
-
getClusterSessionCredentials
default GetClusterSessionCredentialsResponse getClusterSessionCredentials(GetClusterSessionCredentialsRequest getClusterSessionCredentialsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides temporary, HTTP basic credentials that are associated with a given runtime IAM role and used by a cluster with fine-grained access control activated. You can use these credentials to connect to cluster endpoints that support username and password authentication.
- Parameters:
getClusterSessionCredentialsRequest
-- Returns:
- Result of the GetClusterSessionCredentials operation returned by the service.
- See Also:
-
getClusterSessionCredentials
default GetClusterSessionCredentialsResponse getClusterSessionCredentials(Consumer<GetClusterSessionCredentialsRequest.Builder> getClusterSessionCredentialsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides temporary, HTTP basic credentials that are associated with a given runtime IAM role and used by a cluster with fine-grained access control activated. You can use these credentials to connect to cluster endpoints that support username and password authentication.
This is a convenience which creates an instance of the
GetClusterSessionCredentialsRequest.Builder
avoiding the need to create one manually viaGetClusterSessionCredentialsRequest.builder()
- Parameters:
getClusterSessionCredentialsRequest
- AConsumer
that will call methods onGetClusterSessionCredentialsRequest.Builder
to create a request.- Returns:
- Result of the GetClusterSessionCredentials operation returned by the service.
- See Also:
-
getManagedScalingPolicy
default GetManagedScalingPolicyResponse getManagedScalingPolicy(GetManagedScalingPolicyRequest getManagedScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Fetches the attached managed scaling policy for an Amazon EMR cluster.
- Parameters:
getManagedScalingPolicyRequest
-- Returns:
- Result of the GetManagedScalingPolicy operation returned by the service.
- See Also:
-
getManagedScalingPolicy
default GetManagedScalingPolicyResponse getManagedScalingPolicy(Consumer<GetManagedScalingPolicyRequest.Builder> getManagedScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Fetches the attached managed scaling policy for an Amazon EMR cluster.
This is a convenience which creates an instance of the
GetManagedScalingPolicyRequest.Builder
avoiding the need to create one manually viaGetManagedScalingPolicyRequest.builder()
- Parameters:
getManagedScalingPolicyRequest
- AConsumer
that will call methods onGetManagedScalingPolicyRequest.Builder
to create a request.- Returns:
- Result of the GetManagedScalingPolicy operation returned by the service.
- See Also:
-
getStudioSessionMapping
default GetStudioSessionMappingResponse getStudioSessionMapping(GetStudioSessionMappingRequest getStudioSessionMappingRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Fetches mapping details for the specified Amazon EMR Studio and identity (user or group).
- Parameters:
getStudioSessionMappingRequest
-- Returns:
- Result of the GetStudioSessionMapping operation returned by the service.
- See Also:
-
getStudioSessionMapping
default GetStudioSessionMappingResponse getStudioSessionMapping(Consumer<GetStudioSessionMappingRequest.Builder> getStudioSessionMappingRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Fetches mapping details for the specified Amazon EMR Studio and identity (user or group).
This is a convenience which creates an instance of the
GetStudioSessionMappingRequest.Builder
avoiding the need to create one manually viaGetStudioSessionMappingRequest.builder()
- Parameters:
getStudioSessionMappingRequest
- AConsumer
that will call methods onGetStudioSessionMappingRequest.Builder
to create a request.- Returns:
- Result of the GetStudioSessionMapping operation returned by the service.
- See Also:
-
listBootstrapActions
default ListBootstrapActionsResponse listBootstrapActions(ListBootstrapActionsRequest listBootstrapActionsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides information about the bootstrap actions associated with a cluster.
- Parameters:
listBootstrapActionsRequest
- This input determines which bootstrap actions to retrieve.- Returns:
- Result of the ListBootstrapActions operation returned by the service.
- See Also:
-
listBootstrapActions
default ListBootstrapActionsResponse listBootstrapActions(Consumer<ListBootstrapActionsRequest.Builder> listBootstrapActionsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides information about the bootstrap actions associated with a cluster.
This is a convenience which creates an instance of the
ListBootstrapActionsRequest.Builder
avoiding the need to create one manually viaListBootstrapActionsRequest.builder()
- Parameters:
listBootstrapActionsRequest
- AConsumer
that will call methods onListBootstrapActionsRequest.Builder
to create a request. This input determines which bootstrap actions to retrieve.- Returns:
- Result of the ListBootstrapActions operation returned by the service.
- See Also:
-
listBootstrapActionsPaginator
default ListBootstrapActionsIterable listBootstrapActionsPaginator(ListBootstrapActionsRequest listBootstrapActionsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listBootstrapActions(software.amazon.awssdk.services.emr.model.ListBootstrapActionsRequest)
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.emr.paginators.ListBootstrapActionsIterable responses = client.listBootstrapActionsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListBootstrapActionsIterable responses = client .listBootstrapActionsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListBootstrapActionsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListBootstrapActionsIterable responses = client.listBootstrapActionsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listBootstrapActions(software.amazon.awssdk.services.emr.model.ListBootstrapActionsRequest)
operation.- Parameters:
listBootstrapActionsRequest
- This input determines which bootstrap actions to retrieve.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listBootstrapActionsPaginator
default ListBootstrapActionsIterable listBootstrapActionsPaginator(Consumer<ListBootstrapActionsRequest.Builder> listBootstrapActionsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listBootstrapActions(software.amazon.awssdk.services.emr.model.ListBootstrapActionsRequest)
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.emr.paginators.ListBootstrapActionsIterable responses = client.listBootstrapActionsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListBootstrapActionsIterable responses = client .listBootstrapActionsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListBootstrapActionsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListBootstrapActionsIterable responses = client.listBootstrapActionsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listBootstrapActions(software.amazon.awssdk.services.emr.model.ListBootstrapActionsRequest)
operation.
This is a convenience which creates an instance of the
ListBootstrapActionsRequest.Builder
avoiding the need to create one manually viaListBootstrapActionsRequest.builder()
- Parameters:
listBootstrapActionsRequest
- AConsumer
that will call methods onListBootstrapActionsRequest.Builder
to create a request. This input determines which bootstrap actions to retrieve.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listClusters
default ListClustersResponse listClusters(ListClustersRequest listClustersRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides the status of all clusters visible to this Amazon Web Services account. Allows you to filter the list of clusters based on certain criteria; for example, filtering by cluster creation date and time or by status. This call returns a maximum of 50 clusters in unsorted order per call, but returns a marker to track the paging of the cluster list across multiple ListClusters calls.
- Parameters:
listClustersRequest
- This input determines how the ListClusters action filters the list of clusters that it returns.- Returns:
- Result of the ListClusters operation returned by the service.
- See Also:
-
listClusters
default ListClustersResponse listClusters(Consumer<ListClustersRequest.Builder> listClustersRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides the status of all clusters visible to this Amazon Web Services account. Allows you to filter the list of clusters based on certain criteria; for example, filtering by cluster creation date and time or by status. This call returns a maximum of 50 clusters in unsorted order per call, but returns a marker to track the paging of the cluster list across multiple ListClusters calls.
This is a convenience which creates an instance of the
ListClustersRequest.Builder
avoiding the need to create one manually viaListClustersRequest.builder()
- Parameters:
listClustersRequest
- AConsumer
that will call methods onListClustersRequest.Builder
to create a request. This input determines how the ListClusters action filters the list of clusters that it returns.- Returns:
- Result of the ListClusters operation returned by the service.
- See Also:
-
listClusters
default ListClustersResponse listClusters() throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrExceptionProvides the status of all clusters visible to this Amazon Web Services account. Allows you to filter the list of clusters based on certain criteria; for example, filtering by cluster creation date and time or by status. This call returns a maximum of 50 clusters in unsorted order per call, but returns a marker to track the paging of the cluster list across multiple ListClusters calls.
- Returns:
- Result of the ListClusters operation returned by the service.
- See Also:
-
listClustersPaginator
default ListClustersIterable listClustersPaginator() throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrExceptionThis is a variant of
listClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
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.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); for (software.amazon.awssdk.services.emr.model.ListClustersResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
operation.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listClustersPaginator
default ListClustersIterable listClustersPaginator(ListClustersRequest listClustersRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
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.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); for (software.amazon.awssdk.services.emr.model.ListClustersResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
operation.- Parameters:
listClustersRequest
- This input determines how the ListClusters action filters the list of clusters that it returns.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listClustersPaginator
default ListClustersIterable listClustersPaginator(Consumer<ListClustersRequest.Builder> listClustersRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
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.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); for (software.amazon.awssdk.services.emr.model.ListClustersResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListClustersIterable responses = client.listClustersPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)
operation.
This is a convenience which creates an instance of the
ListClustersRequest.Builder
avoiding the need to create one manually viaListClustersRequest.builder()
- Parameters:
listClustersRequest
- AConsumer
that will call methods onListClustersRequest.Builder
to create a request. This input determines how the ListClusters action filters the list of clusters that it returns.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listInstanceFleets
default ListInstanceFleetsResponse listInstanceFleets(ListInstanceFleetsRequest listInstanceFleetsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Lists all available details about the instance fleets in a cluster.
The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
- Parameters:
listInstanceFleetsRequest
-- Returns:
- Result of the ListInstanceFleets operation returned by the service.
- See Also:
-
listInstanceFleets
default ListInstanceFleetsResponse listInstanceFleets(Consumer<ListInstanceFleetsRequest.Builder> listInstanceFleetsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Lists all available details about the instance fleets in a cluster.
The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
This is a convenience which creates an instance of the
ListInstanceFleetsRequest.Builder
avoiding the need to create one manually viaListInstanceFleetsRequest.builder()
- Parameters:
listInstanceFleetsRequest
- AConsumer
that will call methods onListInstanceFleetsRequest.Builder
to create a request.- Returns:
- Result of the ListInstanceFleets operation returned by the service.
- See Also:
-
listInstanceFleetsPaginator
default ListInstanceFleetsIterable listInstanceFleetsPaginator(ListInstanceFleetsRequest listInstanceFleetsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listInstanceFleets(software.amazon.awssdk.services.emr.model.ListInstanceFleetsRequest)
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.emr.paginators.ListInstanceFleetsIterable responses = client.listInstanceFleetsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListInstanceFleetsIterable responses = client .listInstanceFleetsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListInstanceFleetsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListInstanceFleetsIterable responses = client.listInstanceFleetsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listInstanceFleets(software.amazon.awssdk.services.emr.model.ListInstanceFleetsRequest)
operation.- Parameters:
listInstanceFleetsRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listInstanceFleetsPaginator
default ListInstanceFleetsIterable listInstanceFleetsPaginator(Consumer<ListInstanceFleetsRequest.Builder> listInstanceFleetsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listInstanceFleets(software.amazon.awssdk.services.emr.model.ListInstanceFleetsRequest)
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.emr.paginators.ListInstanceFleetsIterable responses = client.listInstanceFleetsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListInstanceFleetsIterable responses = client .listInstanceFleetsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListInstanceFleetsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListInstanceFleetsIterable responses = client.listInstanceFleetsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listInstanceFleets(software.amazon.awssdk.services.emr.model.ListInstanceFleetsRequest)
operation.
This is a convenience which creates an instance of the
ListInstanceFleetsRequest.Builder
avoiding the need to create one manually viaListInstanceFleetsRequest.builder()
- Parameters:
listInstanceFleetsRequest
- AConsumer
that will call methods onListInstanceFleetsRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listInstanceGroups
default ListInstanceGroupsResponse listInstanceGroups(ListInstanceGroupsRequest listInstanceGroupsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides all available details about the instance groups in a cluster.
- Parameters:
listInstanceGroupsRequest
- This input determines which instance groups to retrieve.- Returns:
- Result of the ListInstanceGroups operation returned by the service.
- See Also:
-
listInstanceGroups
default ListInstanceGroupsResponse listInstanceGroups(Consumer<ListInstanceGroupsRequest.Builder> listInstanceGroupsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides all available details about the instance groups in a cluster.
This is a convenience which creates an instance of the
ListInstanceGroupsRequest.Builder
avoiding the need to create one manually viaListInstanceGroupsRequest.builder()
- Parameters:
listInstanceGroupsRequest
- AConsumer
that will call methods onListInstanceGroupsRequest.Builder
to create a request. This input determines which instance groups to retrieve.- Returns:
- Result of the ListInstanceGroups operation returned by the service.
- See Also:
-
listInstanceGroupsPaginator
default ListInstanceGroupsIterable listInstanceGroupsPaginator(ListInstanceGroupsRequest listInstanceGroupsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listInstanceGroups(software.amazon.awssdk.services.emr.model.ListInstanceGroupsRequest)
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.emr.paginators.ListInstanceGroupsIterable responses = client.listInstanceGroupsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListInstanceGroupsIterable responses = client .listInstanceGroupsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListInstanceGroupsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListInstanceGroupsIterable responses = client.listInstanceGroupsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listInstanceGroups(software.amazon.awssdk.services.emr.model.ListInstanceGroupsRequest)
operation.- Parameters:
listInstanceGroupsRequest
- This input determines which instance groups to retrieve.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listInstanceGroupsPaginator
default ListInstanceGroupsIterable listInstanceGroupsPaginator(Consumer<ListInstanceGroupsRequest.Builder> listInstanceGroupsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listInstanceGroups(software.amazon.awssdk.services.emr.model.ListInstanceGroupsRequest)
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.emr.paginators.ListInstanceGroupsIterable responses = client.listInstanceGroupsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListInstanceGroupsIterable responses = client .listInstanceGroupsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListInstanceGroupsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListInstanceGroupsIterable responses = client.listInstanceGroupsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listInstanceGroups(software.amazon.awssdk.services.emr.model.ListInstanceGroupsRequest)
operation.
This is a convenience which creates an instance of the
ListInstanceGroupsRequest.Builder
avoiding the need to create one manually viaListInstanceGroupsRequest.builder()
- Parameters:
listInstanceGroupsRequest
- AConsumer
that will call methods onListInstanceGroupsRequest.Builder
to create a request. This input determines which instance groups to retrieve.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listInstances
default ListInstancesResponse listInstances(ListInstancesRequest listInstancesRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides information for all active Amazon EC2 instances and Amazon EC2 instances terminated in the last 30 days, up to a maximum of 2,000. Amazon EC2 instances in any of the following states are considered active: AWAITING_FULFILLMENT, PROVISIONING, BOOTSTRAPPING, RUNNING.
- Parameters:
listInstancesRequest
- This input determines which instances to list.- Returns:
- Result of the ListInstances operation returned by the service.
- See Also:
-
listInstances
default ListInstancesResponse listInstances(Consumer<ListInstancesRequest.Builder> listInstancesRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides information for all active Amazon EC2 instances and Amazon EC2 instances terminated in the last 30 days, up to a maximum of 2,000. Amazon EC2 instances in any of the following states are considered active: AWAITING_FULFILLMENT, PROVISIONING, BOOTSTRAPPING, RUNNING.
This is a convenience which creates an instance of the
ListInstancesRequest.Builder
avoiding the need to create one manually viaListInstancesRequest.builder()
- Parameters:
listInstancesRequest
- AConsumer
that will call methods onListInstancesRequest.Builder
to create a request. This input determines which instances to list.- Returns:
- Result of the ListInstances operation returned by the service.
- See Also:
-
listInstancesPaginator
default ListInstancesIterable listInstancesPaginator(ListInstancesRequest listInstancesRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listInstances(software.amazon.awssdk.services.emr.model.ListInstancesRequest)
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.emr.paginators.ListInstancesIterable responses = client.listInstancesPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListInstancesIterable responses = client.listInstancesPaginator(request); for (software.amazon.awssdk.services.emr.model.ListInstancesResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListInstancesIterable responses = client.listInstancesPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listInstances(software.amazon.awssdk.services.emr.model.ListInstancesRequest)
operation.- Parameters:
listInstancesRequest
- This input determines which instances to list.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listInstancesPaginator
default ListInstancesIterable listInstancesPaginator(Consumer<ListInstancesRequest.Builder> listInstancesRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listInstances(software.amazon.awssdk.services.emr.model.ListInstancesRequest)
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.emr.paginators.ListInstancesIterable responses = client.listInstancesPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListInstancesIterable responses = client.listInstancesPaginator(request); for (software.amazon.awssdk.services.emr.model.ListInstancesResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListInstancesIterable responses = client.listInstancesPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listInstances(software.amazon.awssdk.services.emr.model.ListInstancesRequest)
operation.
This is a convenience which creates an instance of the
ListInstancesRequest.Builder
avoiding the need to create one manually viaListInstancesRequest.builder()
- Parameters:
listInstancesRequest
- AConsumer
that will call methods onListInstancesRequest.Builder
to create a request. This input determines which instances to list.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listNotebookExecutions
default ListNotebookExecutionsResponse listNotebookExecutions(ListNotebookExecutionsRequest listNotebookExecutionsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides summaries of all notebook executions. You can filter the list based on multiple criteria such as status, time range, and editor id. Returns a maximum of 50 notebook executions and a marker to track the paging of a longer notebook execution list across multiple
ListNotebookExecutions
calls.- Parameters:
listNotebookExecutionsRequest
-- Returns:
- Result of the ListNotebookExecutions operation returned by the service.
- See Also:
-
listNotebookExecutions
default ListNotebookExecutionsResponse listNotebookExecutions(Consumer<ListNotebookExecutionsRequest.Builder> listNotebookExecutionsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides summaries of all notebook executions. You can filter the list based on multiple criteria such as status, time range, and editor id. Returns a maximum of 50 notebook executions and a marker to track the paging of a longer notebook execution list across multiple
ListNotebookExecutions
calls.
This is a convenience which creates an instance of the
ListNotebookExecutionsRequest.Builder
avoiding the need to create one manually viaListNotebookExecutionsRequest.builder()
- Parameters:
listNotebookExecutionsRequest
- AConsumer
that will call methods onListNotebookExecutionsRequest.Builder
to create a request.- Returns:
- Result of the ListNotebookExecutions operation returned by the service.
- See Also:
-
listNotebookExecutionsPaginator
default ListNotebookExecutionsIterable listNotebookExecutionsPaginator(ListNotebookExecutionsRequest listNotebookExecutionsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listNotebookExecutions(software.amazon.awssdk.services.emr.model.ListNotebookExecutionsRequest)
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.emr.paginators.ListNotebookExecutionsIterable responses = client.listNotebookExecutionsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListNotebookExecutionsIterable responses = client .listNotebookExecutionsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListNotebookExecutionsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListNotebookExecutionsIterable responses = client.listNotebookExecutionsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listNotebookExecutions(software.amazon.awssdk.services.emr.model.ListNotebookExecutionsRequest)
operation.- Parameters:
listNotebookExecutionsRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listNotebookExecutionsPaginator
default ListNotebookExecutionsIterable listNotebookExecutionsPaginator(Consumer<ListNotebookExecutionsRequest.Builder> listNotebookExecutionsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listNotebookExecutions(software.amazon.awssdk.services.emr.model.ListNotebookExecutionsRequest)
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.emr.paginators.ListNotebookExecutionsIterable responses = client.listNotebookExecutionsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListNotebookExecutionsIterable responses = client .listNotebookExecutionsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListNotebookExecutionsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListNotebookExecutionsIterable responses = client.listNotebookExecutionsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listNotebookExecutions(software.amazon.awssdk.services.emr.model.ListNotebookExecutionsRequest)
operation.
This is a convenience which creates an instance of the
ListNotebookExecutionsRequest.Builder
avoiding the need to create one manually viaListNotebookExecutionsRequest.builder()
- Parameters:
listNotebookExecutionsRequest
- AConsumer
that will call methods onListNotebookExecutionsRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listReleaseLabels
default ListReleaseLabelsResponse listReleaseLabels(ListReleaseLabelsRequest listReleaseLabelsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Retrieves release labels of Amazon EMR services in the Region where the API is called.
- Parameters:
listReleaseLabelsRequest
-- Returns:
- Result of the ListReleaseLabels operation returned by the service.
- See Also:
-
listReleaseLabels
default ListReleaseLabelsResponse listReleaseLabels(Consumer<ListReleaseLabelsRequest.Builder> listReleaseLabelsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Retrieves release labels of Amazon EMR services in the Region where the API is called.
This is a convenience which creates an instance of the
ListReleaseLabelsRequest.Builder
avoiding the need to create one manually viaListReleaseLabelsRequest.builder()
- Parameters:
listReleaseLabelsRequest
- AConsumer
that will call methods onListReleaseLabelsRequest.Builder
to create a request.- Returns:
- Result of the ListReleaseLabels operation returned by the service.
- See Also:
-
listReleaseLabelsPaginator
default ListReleaseLabelsIterable listReleaseLabelsPaginator(ListReleaseLabelsRequest listReleaseLabelsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listReleaseLabels(software.amazon.awssdk.services.emr.model.ListReleaseLabelsRequest)
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.emr.paginators.ListReleaseLabelsIterable responses = client.listReleaseLabelsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListReleaseLabelsIterable responses = client .listReleaseLabelsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListReleaseLabelsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListReleaseLabelsIterable responses = client.listReleaseLabelsPaginator(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
listReleaseLabels(software.amazon.awssdk.services.emr.model.ListReleaseLabelsRequest)
operation.- Parameters:
listReleaseLabelsRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listReleaseLabelsPaginator
default ListReleaseLabelsIterable listReleaseLabelsPaginator(Consumer<ListReleaseLabelsRequest.Builder> listReleaseLabelsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listReleaseLabels(software.amazon.awssdk.services.emr.model.ListReleaseLabelsRequest)
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.emr.paginators.ListReleaseLabelsIterable responses = client.listReleaseLabelsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListReleaseLabelsIterable responses = client .listReleaseLabelsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListReleaseLabelsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListReleaseLabelsIterable responses = client.listReleaseLabelsPaginator(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
listReleaseLabels(software.amazon.awssdk.services.emr.model.ListReleaseLabelsRequest)
operation.
This is a convenience which creates an instance of the
ListReleaseLabelsRequest.Builder
avoiding the need to create one manually viaListReleaseLabelsRequest.builder()
- Parameters:
listReleaseLabelsRequest
- AConsumer
that will call methods onListReleaseLabelsRequest.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 InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Lists all the security configurations visible to this account, providing their creation dates and times, and their names. This call returns a maximum of 50 clusters per call, but returns a marker to track the paging of the cluster list across multiple ListSecurityConfigurations calls.
- Parameters:
listSecurityConfigurationsRequest
-- Returns:
- Result of the ListSecurityConfigurations operation returned by the service.
- See Also:
-
listSecurityConfigurations
default ListSecurityConfigurationsResponse listSecurityConfigurations(Consumer<ListSecurityConfigurationsRequest.Builder> listSecurityConfigurationsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Lists all the security configurations visible to this account, providing their creation dates and times, and their names. This call returns a maximum of 50 clusters per call, but returns a marker to track the paging of the cluster list across multiple ListSecurityConfigurations calls.
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:
-
listSecurityConfigurations
default ListSecurityConfigurationsResponse listSecurityConfigurations() throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrExceptionLists all the security configurations visible to this account, providing their creation dates and times, and their names. This call returns a maximum of 50 clusters per call, but returns a marker to track the paging of the cluster list across multiple ListSecurityConfigurations calls.
- Returns:
- Result of the ListSecurityConfigurations operation returned by the service.
- See Also:
-
listSecurityConfigurationsPaginator
default ListSecurityConfigurationsIterable listSecurityConfigurationsPaginator() throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrExceptionThis is a variant of
listSecurityConfigurations(software.amazon.awssdk.services.emr.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.emr.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListSecurityConfigurationsIterable responses = client .listSecurityConfigurationsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListSecurityConfigurationsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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.emr.model.ListSecurityConfigurationsRequest)
operation.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listSecurityConfigurationsPaginator
default ListSecurityConfigurationsIterable listSecurityConfigurationsPaginator(ListSecurityConfigurationsRequest listSecurityConfigurationsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listSecurityConfigurations(software.amazon.awssdk.services.emr.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.emr.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListSecurityConfigurationsIterable responses = client .listSecurityConfigurationsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListSecurityConfigurationsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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.emr.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 InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listSecurityConfigurations(software.amazon.awssdk.services.emr.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.emr.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListSecurityConfigurationsIterable responses = client .listSecurityConfigurationsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListSecurityConfigurationsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListSecurityConfigurationsIterable responses = client.listSecurityConfigurationsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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.emr.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:
-
listSteps
default ListStepsResponse listSteps(ListStepsRequest listStepsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides a list of steps for the cluster in reverse order unless you specify
stepIds
with the request or filter byStepStates
. You can specify a maximum of 10stepIDs
. The CLI automatically paginates results to return a list greater than 50 steps. To return more than 50 steps using the CLI, specify aMarker
, which is a pagination token that indicates the next set of steps to retrieve.- Parameters:
listStepsRequest
- This input determines which steps to list.- Returns:
- Result of the ListSteps operation returned by the service.
- See Also:
-
listSteps
default ListStepsResponse listSteps(Consumer<ListStepsRequest.Builder> listStepsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Provides a list of steps for the cluster in reverse order unless you specify
stepIds
with the request or filter byStepStates
. You can specify a maximum of 10stepIDs
. The CLI automatically paginates results to return a list greater than 50 steps. To return more than 50 steps using the CLI, specify aMarker
, which is a pagination token that indicates the next set of steps to retrieve.
This is a convenience which creates an instance of the
ListStepsRequest.Builder
avoiding the need to create one manually viaListStepsRequest.builder()
- Parameters:
listStepsRequest
- AConsumer
that will call methods onListStepsRequest.Builder
to create a request. This input determines which steps to list.- Returns:
- Result of the ListSteps operation returned by the service.
- See Also:
-
listStepsPaginator
default ListStepsIterable listStepsPaginator(ListStepsRequest listStepsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listSteps(software.amazon.awssdk.services.emr.model.ListStepsRequest)
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.emr.paginators.ListStepsIterable responses = client.listStepsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListStepsIterable responses = client.listStepsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListStepsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListStepsIterable responses = client.listStepsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listSteps(software.amazon.awssdk.services.emr.model.ListStepsRequest)
operation.- Parameters:
listStepsRequest
- This input determines which steps to list.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listStepsPaginator
default ListStepsIterable listStepsPaginator(Consumer<ListStepsRequest.Builder> listStepsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listSteps(software.amazon.awssdk.services.emr.model.ListStepsRequest)
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.emr.paginators.ListStepsIterable responses = client.listStepsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListStepsIterable responses = client.listStepsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListStepsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListStepsIterable responses = client.listStepsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listSteps(software.amazon.awssdk.services.emr.model.ListStepsRequest)
operation.
This is a convenience which creates an instance of the
ListStepsRequest.Builder
avoiding the need to create one manually viaListStepsRequest.builder()
- Parameters:
listStepsRequest
- AConsumer
that will call methods onListStepsRequest.Builder
to create a request. This input determines which steps to list.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listStudioSessionMappings
default ListStudioSessionMappingsResponse listStudioSessionMappings(ListStudioSessionMappingsRequest listStudioSessionMappingsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Returns a list of all user or group session mappings for the Amazon EMR Studio specified by
StudioId
.- Parameters:
listStudioSessionMappingsRequest
-- Returns:
- Result of the ListStudioSessionMappings operation returned by the service.
- See Also:
-
listStudioSessionMappings
default ListStudioSessionMappingsResponse listStudioSessionMappings(Consumer<ListStudioSessionMappingsRequest.Builder> listStudioSessionMappingsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Returns a list of all user or group session mappings for the Amazon EMR Studio specified by
StudioId
.
This is a convenience which creates an instance of the
ListStudioSessionMappingsRequest.Builder
avoiding the need to create one manually viaListStudioSessionMappingsRequest.builder()
- Parameters:
listStudioSessionMappingsRequest
- AConsumer
that will call methods onListStudioSessionMappingsRequest.Builder
to create a request.- Returns:
- Result of the ListStudioSessionMappings operation returned by the service.
- See Also:
-
listStudioSessionMappingsPaginator
default ListStudioSessionMappingsIterable listStudioSessionMappingsPaginator(ListStudioSessionMappingsRequest listStudioSessionMappingsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listStudioSessionMappings(software.amazon.awssdk.services.emr.model.ListStudioSessionMappingsRequest)
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.emr.paginators.ListStudioSessionMappingsIterable responses = client.listStudioSessionMappingsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListStudioSessionMappingsIterable responses = client .listStudioSessionMappingsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListStudioSessionMappingsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListStudioSessionMappingsIterable responses = client.listStudioSessionMappingsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listStudioSessionMappings(software.amazon.awssdk.services.emr.model.ListStudioSessionMappingsRequest)
operation.- Parameters:
listStudioSessionMappingsRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listStudioSessionMappingsPaginator
default ListStudioSessionMappingsIterable listStudioSessionMappingsPaginator(Consumer<ListStudioSessionMappingsRequest.Builder> listStudioSessionMappingsRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listStudioSessionMappings(software.amazon.awssdk.services.emr.model.ListStudioSessionMappingsRequest)
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.emr.paginators.ListStudioSessionMappingsIterable responses = client.listStudioSessionMappingsPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListStudioSessionMappingsIterable responses = client .listStudioSessionMappingsPaginator(request); for (software.amazon.awssdk.services.emr.model.ListStudioSessionMappingsResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListStudioSessionMappingsIterable responses = client.listStudioSessionMappingsPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listStudioSessionMappings(software.amazon.awssdk.services.emr.model.ListStudioSessionMappingsRequest)
operation.
This is a convenience which creates an instance of the
ListStudioSessionMappingsRequest.Builder
avoiding the need to create one manually viaListStudioSessionMappingsRequest.builder()
- Parameters:
listStudioSessionMappingsRequest
- AConsumer
that will call methods onListStudioSessionMappingsRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listStudios
default ListStudiosResponse listStudios(ListStudiosRequest listStudiosRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Returns a list of all Amazon EMR Studios associated with the Amazon Web Services account. The list includes details such as ID, Studio Access URL, and creation time for each Studio.
- Parameters:
listStudiosRequest
-- Returns:
- Result of the ListStudios operation returned by the service.
- See Also:
-
listStudios
default ListStudiosResponse listStudios(Consumer<ListStudiosRequest.Builder> listStudiosRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Returns a list of all Amazon EMR Studios associated with the Amazon Web Services account. The list includes details such as ID, Studio Access URL, and creation time for each Studio.
This is a convenience which creates an instance of the
ListStudiosRequest.Builder
avoiding the need to create one manually viaListStudiosRequest.builder()
- Parameters:
listStudiosRequest
- AConsumer
that will call methods onListStudiosRequest.Builder
to create a request.- Returns:
- Result of the ListStudios operation returned by the service.
- See Also:
-
listStudiosPaginator
default ListStudiosIterable listStudiosPaginator(ListStudiosRequest listStudiosRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listStudios(software.amazon.awssdk.services.emr.model.ListStudiosRequest)
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.emr.paginators.ListStudiosIterable responses = client.listStudiosPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListStudiosIterable responses = client.listStudiosPaginator(request); for (software.amazon.awssdk.services.emr.model.ListStudiosResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListStudiosIterable responses = client.listStudiosPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listStudios(software.amazon.awssdk.services.emr.model.ListStudiosRequest)
operation.- Parameters:
listStudiosRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listStudiosPaginator
default ListStudiosIterable listStudiosPaginator(Consumer<ListStudiosRequest.Builder> listStudiosRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listStudios(software.amazon.awssdk.services.emr.model.ListStudiosRequest)
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.emr.paginators.ListStudiosIterable responses = client.listStudiosPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListStudiosIterable responses = client.listStudiosPaginator(request); for (software.amazon.awssdk.services.emr.model.ListStudiosResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListStudiosIterable responses = client.listStudiosPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listStudios(software.amazon.awssdk.services.emr.model.ListStudiosRequest)
operation.
This is a convenience which creates an instance of the
ListStudiosRequest.Builder
avoiding the need to create one manually viaListStudiosRequest.builder()
- Parameters:
listStudiosRequest
- AConsumer
that will call methods onListStudiosRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listSupportedInstanceTypes
default ListSupportedInstanceTypesResponse listSupportedInstanceTypes(ListSupportedInstanceTypesRequest listSupportedInstanceTypesRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException A list of the instance types that Amazon EMR supports. You can filter the list by Amazon Web Services Region and Amazon EMR release.
- Parameters:
listSupportedInstanceTypesRequest
-- Returns:
- Result of the ListSupportedInstanceTypes operation returned by the service.
- See Also:
-
listSupportedInstanceTypes
default ListSupportedInstanceTypesResponse listSupportedInstanceTypes(Consumer<ListSupportedInstanceTypesRequest.Builder> listSupportedInstanceTypesRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException A list of the instance types that Amazon EMR supports. You can filter the list by Amazon Web Services Region and Amazon EMR release.
This is a convenience which creates an instance of the
ListSupportedInstanceTypesRequest.Builder
avoiding the need to create one manually viaListSupportedInstanceTypesRequest.builder()
- Parameters:
listSupportedInstanceTypesRequest
- AConsumer
that will call methods onListSupportedInstanceTypesRequest.Builder
to create a request.- Returns:
- Result of the ListSupportedInstanceTypes operation returned by the service.
- See Also:
-
listSupportedInstanceTypesPaginator
default ListSupportedInstanceTypesIterable listSupportedInstanceTypesPaginator(ListSupportedInstanceTypesRequest listSupportedInstanceTypesRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listSupportedInstanceTypes(software.amazon.awssdk.services.emr.model.ListSupportedInstanceTypesRequest)
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.emr.paginators.ListSupportedInstanceTypesIterable responses = client.listSupportedInstanceTypesPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListSupportedInstanceTypesIterable responses = client .listSupportedInstanceTypesPaginator(request); for (software.amazon.awssdk.services.emr.model.ListSupportedInstanceTypesResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListSupportedInstanceTypesIterable responses = client.listSupportedInstanceTypesPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listSupportedInstanceTypes(software.amazon.awssdk.services.emr.model.ListSupportedInstanceTypesRequest)
operation.- Parameters:
listSupportedInstanceTypesRequest
-- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
listSupportedInstanceTypesPaginator
default ListSupportedInstanceTypesIterable listSupportedInstanceTypesPaginator(Consumer<ListSupportedInstanceTypesRequest.Builder> listSupportedInstanceTypesRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException This is a variant of
listSupportedInstanceTypes(software.amazon.awssdk.services.emr.model.ListSupportedInstanceTypesRequest)
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.emr.paginators.ListSupportedInstanceTypesIterable responses = client.listSupportedInstanceTypesPaginator(request); responses.stream().forEach(....);
{ @code software.amazon.awssdk.services.emr.paginators.ListSupportedInstanceTypesIterable responses = client .listSupportedInstanceTypesPaginator(request); for (software.amazon.awssdk.services.emr.model.ListSupportedInstanceTypesResponse response : responses) { // do something; } }
3) Use iterator directlysoftware.amazon.awssdk.services.emr.paginators.ListSupportedInstanceTypesIterable responses = client.listSupportedInstanceTypesPaginator(request); responses.iterator().forEachRemaining(....);
Please notice that the configuration of null 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
listSupportedInstanceTypes(software.amazon.awssdk.services.emr.model.ListSupportedInstanceTypesRequest)
operation.
This is a convenience which creates an instance of the
ListSupportedInstanceTypesRequest.Builder
avoiding the need to create one manually viaListSupportedInstanceTypesRequest.builder()
- Parameters:
listSupportedInstanceTypesRequest
- AConsumer
that will call methods onListSupportedInstanceTypesRequest.Builder
to create a request.- Returns:
- A custom iterable that can be used to iterate through all the response pages.
- See Also:
-
modifyCluster
default ModifyClusterResponse modifyCluster(ModifyClusterRequest modifyClusterRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Modifies the number of steps that can be executed concurrently for the cluster specified using ClusterID.
- Parameters:
modifyClusterRequest
-- Returns:
- Result of the ModifyCluster operation returned by the service.
- See Also:
-
modifyCluster
default ModifyClusterResponse modifyCluster(Consumer<ModifyClusterRequest.Builder> modifyClusterRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Modifies the number of steps that can be executed concurrently for the cluster specified using ClusterID.
This is a convenience which creates an instance of the
ModifyClusterRequest.Builder
avoiding the need to create one manually viaModifyClusterRequest.builder()
- Parameters:
modifyClusterRequest
- AConsumer
that will call methods onModifyClusterRequest.Builder
to create a request.- Returns:
- Result of the ModifyCluster operation returned by the service.
- See Also:
-
modifyInstanceFleet
default ModifyInstanceFleetResponse modifyInstanceFleet(ModifyInstanceFleetRequest modifyInstanceFleetRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Modifies the target On-Demand and target Spot capacities for the instance fleet with the specified InstanceFleetID within the cluster specified using ClusterID. The call either succeeds or fails atomically.
The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
- Parameters:
modifyInstanceFleetRequest
-- Returns:
- Result of the ModifyInstanceFleet operation returned by the service.
- See Also:
-
modifyInstanceFleet
default ModifyInstanceFleetResponse modifyInstanceFleet(Consumer<ModifyInstanceFleetRequest.Builder> modifyInstanceFleetRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Modifies the target On-Demand and target Spot capacities for the instance fleet with the specified InstanceFleetID within the cluster specified using ClusterID. The call either succeeds or fails atomically.
The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
This is a convenience which creates an instance of the
ModifyInstanceFleetRequest.Builder
avoiding the need to create one manually viaModifyInstanceFleetRequest.builder()
- Parameters:
modifyInstanceFleetRequest
- AConsumer
that will call methods onModifyInstanceFleetRequest.Builder
to create a request.- Returns:
- Result of the ModifyInstanceFleet operation returned by the service.
- See Also:
-
modifyInstanceGroups
default ModifyInstanceGroupsResponse modifyInstanceGroups(ModifyInstanceGroupsRequest modifyInstanceGroupsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException ModifyInstanceGroups modifies the number of nodes and configuration settings of an instance group. The input parameters include the new target instance count for the group and the instance group ID. The call will either succeed or fail atomically.
- Parameters:
modifyInstanceGroupsRequest
- Change the size of some instance groups.- Returns:
- Result of the ModifyInstanceGroups operation returned by the service.
- See Also:
-
modifyInstanceGroups
default ModifyInstanceGroupsResponse modifyInstanceGroups(Consumer<ModifyInstanceGroupsRequest.Builder> modifyInstanceGroupsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException ModifyInstanceGroups modifies the number of nodes and configuration settings of an instance group. The input parameters include the new target instance count for the group and the instance group ID. The call will either succeed or fail atomically.
This is a convenience which creates an instance of the
ModifyInstanceGroupsRequest.Builder
avoiding the need to create one manually viaModifyInstanceGroupsRequest.builder()
- Parameters:
modifyInstanceGroupsRequest
- AConsumer
that will call methods onModifyInstanceGroupsRequest.Builder
to create a request. Change the size of some instance groups.- Returns:
- Result of the ModifyInstanceGroups operation returned by the service.
- See Also:
-
putAutoScalingPolicy
default PutAutoScalingPolicyResponse putAutoScalingPolicy(PutAutoScalingPolicyRequest putAutoScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Creates or updates an automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster. The automatic scaling policy defines how an instance group dynamically adds and terminates Amazon EC2 instances in response to the value of a CloudWatch metric.
- Parameters:
putAutoScalingPolicyRequest
-- Returns:
- Result of the PutAutoScalingPolicy operation returned by the service.
- See Also:
-
putAutoScalingPolicy
default PutAutoScalingPolicyResponse putAutoScalingPolicy(Consumer<PutAutoScalingPolicyRequest.Builder> putAutoScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Creates or updates an automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster. The automatic scaling policy defines how an instance group dynamically adds and terminates Amazon EC2 instances in response to the value of a CloudWatch metric.
This is a convenience which creates an instance of the
PutAutoScalingPolicyRequest.Builder
avoiding the need to create one manually viaPutAutoScalingPolicyRequest.builder()
- Parameters:
putAutoScalingPolicyRequest
- AConsumer
that will call methods onPutAutoScalingPolicyRequest.Builder
to create a request.- Returns:
- Result of the PutAutoScalingPolicy operation returned by the service.
- See Also:
-
putAutoTerminationPolicy
default PutAutoTerminationPolicyResponse putAutoTerminationPolicy(PutAutoTerminationPolicyRequest putAutoTerminationPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Auto-termination is supported in Amazon EMR releases 5.30.0 and 6.1.0 and later. For more information, see Using an auto-termination policy.
Creates or updates an auto-termination policy for an Amazon EMR cluster. An auto-termination policy defines the amount of idle time in seconds after which a cluster automatically terminates. For alternative cluster termination options, see Control cluster termination.
- Parameters:
putAutoTerminationPolicyRequest
-- Returns:
- Result of the PutAutoTerminationPolicy operation returned by the service.
- See Also:
-
putAutoTerminationPolicy
default PutAutoTerminationPolicyResponse putAutoTerminationPolicy(Consumer<PutAutoTerminationPolicyRequest.Builder> putAutoTerminationPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Auto-termination is supported in Amazon EMR releases 5.30.0 and 6.1.0 and later. For more information, see Using an auto-termination policy.
Creates or updates an auto-termination policy for an Amazon EMR cluster. An auto-termination policy defines the amount of idle time in seconds after which a cluster automatically terminates. For alternative cluster termination options, see Control cluster termination.
This is a convenience which creates an instance of the
PutAutoTerminationPolicyRequest.Builder
avoiding the need to create one manually viaPutAutoTerminationPolicyRequest.builder()
- Parameters:
putAutoTerminationPolicyRequest
- AConsumer
that will call methods onPutAutoTerminationPolicyRequest.Builder
to create a request.- Returns:
- Result of the PutAutoTerminationPolicy operation returned by the service.
- See Also:
-
putBlockPublicAccessConfiguration
default PutBlockPublicAccessConfigurationResponse putBlockPublicAccessConfiguration(PutBlockPublicAccessConfigurationRequest putBlockPublicAccessConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Creates or updates an Amazon EMR block public access configuration for your Amazon Web Services account in the current Region. For more information see Configure Block Public Access for Amazon EMR in the Amazon EMR Management Guide.
- Parameters:
putBlockPublicAccessConfigurationRequest
-- Returns:
- Result of the PutBlockPublicAccessConfiguration operation returned by the service.
- See Also:
-
putBlockPublicAccessConfiguration
default PutBlockPublicAccessConfigurationResponse putBlockPublicAccessConfiguration(Consumer<PutBlockPublicAccessConfigurationRequest.Builder> putBlockPublicAccessConfigurationRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Creates or updates an Amazon EMR block public access configuration for your Amazon Web Services account in the current Region. For more information see Configure Block Public Access for Amazon EMR in the Amazon EMR Management Guide.
This is a convenience which creates an instance of the
PutBlockPublicAccessConfigurationRequest.Builder
avoiding the need to create one manually viaPutBlockPublicAccessConfigurationRequest.builder()
- Parameters:
putBlockPublicAccessConfigurationRequest
- AConsumer
that will call methods onPutBlockPublicAccessConfigurationRequest.Builder
to create a request.- Returns:
- Result of the PutBlockPublicAccessConfiguration operation returned by the service.
- See Also:
-
putManagedScalingPolicy
default PutManagedScalingPolicyResponse putManagedScalingPolicy(PutManagedScalingPolicyRequest putManagedScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Creates or updates a managed scaling policy for an Amazon EMR cluster. The managed scaling policy defines the limits for resources, such as Amazon EC2 instances that can be added or terminated from a cluster. The policy only applies to the core and task nodes. The master node cannot be scaled after initial configuration.
- Parameters:
putManagedScalingPolicyRequest
-- Returns:
- Result of the PutManagedScalingPolicy operation returned by the service.
- See Also:
-
putManagedScalingPolicy
default PutManagedScalingPolicyResponse putManagedScalingPolicy(Consumer<PutManagedScalingPolicyRequest.Builder> putManagedScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Creates or updates a managed scaling policy for an Amazon EMR cluster. The managed scaling policy defines the limits for resources, such as Amazon EC2 instances that can be added or terminated from a cluster. The policy only applies to the core and task nodes. The master node cannot be scaled after initial configuration.
This is a convenience which creates an instance of the
PutManagedScalingPolicyRequest.Builder
avoiding the need to create one manually viaPutManagedScalingPolicyRequest.builder()
- Parameters:
putManagedScalingPolicyRequest
- AConsumer
that will call methods onPutManagedScalingPolicyRequest.Builder
to create a request.- Returns:
- Result of the PutManagedScalingPolicy operation returned by the service.
- See Also:
-
removeAutoScalingPolicy
default RemoveAutoScalingPolicyResponse removeAutoScalingPolicy(RemoveAutoScalingPolicyRequest removeAutoScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Removes an automatic scaling policy from a specified instance group within an Amazon EMR cluster.
- Parameters:
removeAutoScalingPolicyRequest
-- Returns:
- Result of the RemoveAutoScalingPolicy operation returned by the service.
- See Also:
-
removeAutoScalingPolicy
default RemoveAutoScalingPolicyResponse removeAutoScalingPolicy(Consumer<RemoveAutoScalingPolicyRequest.Builder> removeAutoScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Removes an automatic scaling policy from a specified instance group within an Amazon EMR cluster.
This is a convenience which creates an instance of the
RemoveAutoScalingPolicyRequest.Builder
avoiding the need to create one manually viaRemoveAutoScalingPolicyRequest.builder()
- Parameters:
removeAutoScalingPolicyRequest
- AConsumer
that will call methods onRemoveAutoScalingPolicyRequest.Builder
to create a request.- Returns:
- Result of the RemoveAutoScalingPolicy operation returned by the service.
- See Also:
-
removeAutoTerminationPolicy
default RemoveAutoTerminationPolicyResponse removeAutoTerminationPolicy(RemoveAutoTerminationPolicyRequest removeAutoTerminationPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Removes an auto-termination policy from an Amazon EMR cluster.
- Parameters:
removeAutoTerminationPolicyRequest
-- Returns:
- Result of the RemoveAutoTerminationPolicy operation returned by the service.
- See Also:
-
removeAutoTerminationPolicy
default RemoveAutoTerminationPolicyResponse removeAutoTerminationPolicy(Consumer<RemoveAutoTerminationPolicyRequest.Builder> removeAutoTerminationPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Removes an auto-termination policy from an Amazon EMR cluster.
This is a convenience which creates an instance of the
RemoveAutoTerminationPolicyRequest.Builder
avoiding the need to create one manually viaRemoveAutoTerminationPolicyRequest.builder()
- Parameters:
removeAutoTerminationPolicyRequest
- AConsumer
that will call methods onRemoveAutoTerminationPolicyRequest.Builder
to create a request.- Returns:
- Result of the RemoveAutoTerminationPolicy operation returned by the service.
- See Also:
-
removeManagedScalingPolicy
default RemoveManagedScalingPolicyResponse removeManagedScalingPolicy(RemoveManagedScalingPolicyRequest removeManagedScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Removes a managed scaling policy from a specified Amazon EMR cluster.
- Parameters:
removeManagedScalingPolicyRequest
-- Returns:
- Result of the RemoveManagedScalingPolicy operation returned by the service.
- See Also:
-
removeManagedScalingPolicy
default RemoveManagedScalingPolicyResponse removeManagedScalingPolicy(Consumer<RemoveManagedScalingPolicyRequest.Builder> removeManagedScalingPolicyRequest) throws AwsServiceException, SdkClientException, EmrException Removes a managed scaling policy from a specified Amazon EMR cluster.
This is a convenience which creates an instance of the
RemoveManagedScalingPolicyRequest.Builder
avoiding the need to create one manually viaRemoveManagedScalingPolicyRequest.builder()
- Parameters:
removeManagedScalingPolicyRequest
- AConsumer
that will call methods onRemoveManagedScalingPolicyRequest.Builder
to create a request.- Returns:
- Result of the RemoveManagedScalingPolicy operation returned by the service.
- See Also:
-
removeTags
default RemoveTagsResponse removeTags(RemoveTagsRequest removeTagsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Removes tags from an Amazon EMR resource, such as a cluster or Amazon EMR Studio. Tags make it easier to associate resources in various ways, such as grouping clusters to track your Amazon EMR resource allocation costs. For more information, see Tag Clusters.
The following example removes the stack tag with value Prod from a cluster:
- Parameters:
removeTagsRequest
- This input identifies an Amazon EMR resource and a list of tags to remove.- Returns:
- Result of the RemoveTags operation returned by the service.
- See Also:
-
removeTags
default RemoveTagsResponse removeTags(Consumer<RemoveTagsRequest.Builder> removeTagsRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Removes tags from an Amazon EMR resource, such as a cluster or Amazon EMR Studio. Tags make it easier to associate resources in various ways, such as grouping clusters to track your Amazon EMR resource allocation costs. For more information, see Tag Clusters.
The following example removes the stack tag with value Prod from a cluster:
This is a convenience which creates an instance of the
RemoveTagsRequest.Builder
avoiding the need to create one manually viaRemoveTagsRequest.builder()
- Parameters:
removeTagsRequest
- AConsumer
that will call methods onRemoveTagsRequest.Builder
to create a request. This input identifies an Amazon EMR resource and a list of tags to remove.- Returns:
- Result of the RemoveTags operation returned by the service.
- See Also:
-
runJobFlow
default RunJobFlowResponse runJobFlow(RunJobFlowRequest runJobFlowRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException RunJobFlow creates and starts running a new cluster (job flow). The cluster runs the steps specified. After the steps complete, the cluster stops and the HDFS partition is lost. To prevent loss of data, configure the last step of the job flow to store results in Amazon S3. If the JobFlowInstancesConfig
KeepJobFlowAliveWhenNoSteps
parameter is set toTRUE
, the cluster transitions to the WAITING state rather than shutting down after the steps have completed.For additional protection, you can set the JobFlowInstancesConfig
TerminationProtected
parameter toTRUE
to lock the cluster and prevent it from being terminated by API call, user intervention, or in the event of a job flow error.A maximum of 256 steps are allowed in each job flow.
If your cluster is long-running (such as a Hive data warehouse) or complex, you may require more than 256 steps to process your data. You can bypass the 256-step limitation in various ways, including using the SSH shell to connect to the master node and submitting queries directly to the software running on the master node, such as Hive and Hadoop.
For long-running clusters, we recommend that you periodically store your results.
The instance fleets configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions. The RunJobFlow request can contain InstanceFleets parameters or InstanceGroups parameters, but not both.
- Parameters:
runJobFlowRequest
- Input to the RunJobFlow operation.- Returns:
- Result of the RunJobFlow operation returned by the service.
- See Also:
-
runJobFlow
default RunJobFlowResponse runJobFlow(Consumer<RunJobFlowRequest.Builder> runJobFlowRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException RunJobFlow creates and starts running a new cluster (job flow). The cluster runs the steps specified. After the steps complete, the cluster stops and the HDFS partition is lost. To prevent loss of data, configure the last step of the job flow to store results in Amazon S3. If the JobFlowInstancesConfig
KeepJobFlowAliveWhenNoSteps
parameter is set toTRUE
, the cluster transitions to the WAITING state rather than shutting down after the steps have completed.For additional protection, you can set the JobFlowInstancesConfig
TerminationProtected
parameter toTRUE
to lock the cluster and prevent it from being terminated by API call, user intervention, or in the event of a job flow error.A maximum of 256 steps are allowed in each job flow.
If your cluster is long-running (such as a Hive data warehouse) or complex, you may require more than 256 steps to process your data. You can bypass the 256-step limitation in various ways, including using the SSH shell to connect to the master node and submitting queries directly to the software running on the master node, such as Hive and Hadoop.
For long-running clusters, we recommend that you periodically store your results.
The instance fleets configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions. The RunJobFlow request can contain InstanceFleets parameters or InstanceGroups parameters, but not both.
This is a convenience which creates an instance of the
RunJobFlowRequest.Builder
avoiding the need to create one manually viaRunJobFlowRequest.builder()
- Parameters:
runJobFlowRequest
- AConsumer
that will call methods onRunJobFlowRequest.Builder
to create a request. Input to the RunJobFlow operation.- Returns:
- Result of the RunJobFlow operation returned by the service.
- See Also:
-
setKeepJobFlowAliveWhenNoSteps
default SetKeepJobFlowAliveWhenNoStepsResponse setKeepJobFlowAliveWhenNoSteps(SetKeepJobFlowAliveWhenNoStepsRequest setKeepJobFlowAliveWhenNoStepsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException You can use the
SetKeepJobFlowAliveWhenNoSteps
to configure a cluster (job flow) to terminate after the step execution, i.e., all your steps are executed. If you want a transient cluster that shuts down after the last of the current executing steps are completed, you can configureSetKeepJobFlowAliveWhenNoSteps
to false. If you want a long running cluster, configureSetKeepJobFlowAliveWhenNoSteps
to true.For more information, see Managing Cluster Termination in the Amazon EMR Management Guide.
- Parameters:
setKeepJobFlowAliveWhenNoStepsRequest
-- Returns:
- Result of the SetKeepJobFlowAliveWhenNoSteps operation returned by the service.
- See Also:
-
setKeepJobFlowAliveWhenNoSteps
default SetKeepJobFlowAliveWhenNoStepsResponse setKeepJobFlowAliveWhenNoSteps(Consumer<SetKeepJobFlowAliveWhenNoStepsRequest.Builder> setKeepJobFlowAliveWhenNoStepsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException You can use the
SetKeepJobFlowAliveWhenNoSteps
to configure a cluster (job flow) to terminate after the step execution, i.e., all your steps are executed. If you want a transient cluster that shuts down after the last of the current executing steps are completed, you can configureSetKeepJobFlowAliveWhenNoSteps
to false. If you want a long running cluster, configureSetKeepJobFlowAliveWhenNoSteps
to true.For more information, see Managing Cluster Termination in the Amazon EMR Management Guide.
This is a convenience which creates an instance of the
SetKeepJobFlowAliveWhenNoStepsRequest.Builder
avoiding the need to create one manually viaSetKeepJobFlowAliveWhenNoStepsRequest.builder()
- Parameters:
setKeepJobFlowAliveWhenNoStepsRequest
- AConsumer
that will call methods onSetKeepJobFlowAliveWhenNoStepsRequest.Builder
to create a request.- Returns:
- Result of the SetKeepJobFlowAliveWhenNoSteps operation returned by the service.
- See Also:
-
setTerminationProtection
default SetTerminationProtectionResponse setTerminationProtection(SetTerminationProtectionRequest setTerminationProtectionRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException SetTerminationProtection locks a cluster (job flow) so the Amazon EC2 instances in the cluster cannot be terminated by user intervention, an API call, or in the event of a job-flow error. The cluster still terminates upon successful completion of the job flow. Calling
SetTerminationProtection
on a cluster is similar to calling the Amazon EC2DisableAPITermination
API on all Amazon EC2 instances in a cluster.SetTerminationProtection
is used to prevent accidental termination of a cluster and to ensure that in the event of an error, the instances persist so that you can recover any data stored in their ephemeral instance storage.To terminate a cluster that has been locked by setting
SetTerminationProtection
totrue
, you must first unlock the job flow by a subsequent call toSetTerminationProtection
in which you set the value tofalse
.For more information, see Managing Cluster Termination in the Amazon EMR Management Guide.
- Parameters:
setTerminationProtectionRequest
- The input argument to the TerminationProtection operation.- Returns:
- Result of the SetTerminationProtection operation returned by the service.
- See Also:
-
setTerminationProtection
default SetTerminationProtectionResponse setTerminationProtection(Consumer<SetTerminationProtectionRequest.Builder> setTerminationProtectionRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException SetTerminationProtection locks a cluster (job flow) so the Amazon EC2 instances in the cluster cannot be terminated by user intervention, an API call, or in the event of a job-flow error. The cluster still terminates upon successful completion of the job flow. Calling
SetTerminationProtection
on a cluster is similar to calling the Amazon EC2DisableAPITermination
API on all Amazon EC2 instances in a cluster.SetTerminationProtection
is used to prevent accidental termination of a cluster and to ensure that in the event of an error, the instances persist so that you can recover any data stored in their ephemeral instance storage.To terminate a cluster that has been locked by setting
SetTerminationProtection
totrue
, you must first unlock the job flow by a subsequent call toSetTerminationProtection
in which you set the value tofalse
.For more information, see Managing Cluster Termination in the Amazon EMR Management Guide.
This is a convenience which creates an instance of the
SetTerminationProtectionRequest.Builder
avoiding the need to create one manually viaSetTerminationProtectionRequest.builder()
- Parameters:
setTerminationProtectionRequest
- AConsumer
that will call methods onSetTerminationProtectionRequest.Builder
to create a request. The input argument to the TerminationProtection operation.- Returns:
- Result of the SetTerminationProtection operation returned by the service.
- See Also:
-
setUnhealthyNodeReplacement
default SetUnhealthyNodeReplacementResponse setUnhealthyNodeReplacement(SetUnhealthyNodeReplacementRequest setUnhealthyNodeReplacementRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException Specify whether to enable unhealthy node replacement, which lets Amazon EMR gracefully replace core nodes on a cluster if any nodes become unhealthy. For example, a node becomes unhealthy if disk usage is above 90%. If unhealthy node replacement is on and
TerminationProtected
are off, Amazon EMR immediately terminates the unhealthy core nodes. To use unhealthy node replacement and retain unhealthy core nodes, use to turn on termination protection. In such cases, Amazon EMR adds the unhealthy nodes to a denylist, reducing job interruptions and failures.If unhealthy node replacement is on, Amazon EMR notifies YARN and other applications on the cluster to stop scheduling tasks with these nodes, moves the data, and then terminates the nodes.
For more information, see graceful node replacement in the Amazon EMR Management Guide.
- Parameters:
setUnhealthyNodeReplacementRequest
-- Returns:
- Result of the SetUnhealthyNodeReplacement operation returned by the service.
- See Also:
-
setUnhealthyNodeReplacement
default SetUnhealthyNodeReplacementResponse setUnhealthyNodeReplacement(Consumer<SetUnhealthyNodeReplacementRequest.Builder> setUnhealthyNodeReplacementRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException Specify whether to enable unhealthy node replacement, which lets Amazon EMR gracefully replace core nodes on a cluster if any nodes become unhealthy. For example, a node becomes unhealthy if disk usage is above 90%. If unhealthy node replacement is on and
TerminationProtected
are off, Amazon EMR immediately terminates the unhealthy core nodes. To use unhealthy node replacement and retain unhealthy core nodes, use to turn on termination protection. In such cases, Amazon EMR adds the unhealthy nodes to a denylist, reducing job interruptions and failures.If unhealthy node replacement is on, Amazon EMR notifies YARN and other applications on the cluster to stop scheduling tasks with these nodes, moves the data, and then terminates the nodes.
For more information, see graceful node replacement in the Amazon EMR Management Guide.
This is a convenience which creates an instance of the
SetUnhealthyNodeReplacementRequest.Builder
avoiding the need to create one manually viaSetUnhealthyNodeReplacementRequest.builder()
- Parameters:
setUnhealthyNodeReplacementRequest
- AConsumer
that will call methods onSetUnhealthyNodeReplacementRequest.Builder
to create a request.- Returns:
- Result of the SetUnhealthyNodeReplacement operation returned by the service.
- See Also:
-
setVisibleToAllUsers
default SetVisibleToAllUsersResponse setVisibleToAllUsers(SetVisibleToAllUsersRequest setVisibleToAllUsersRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException The SetVisibleToAllUsers parameter is no longer supported. Your cluster may be visible to all users in your account. To restrict cluster access using an IAM policy, see Identity and Access Management for Amazon EMR.
Sets the Clusterinvalid input: '$'VisibleToAllUsers value for an Amazon EMR cluster. When
true
, IAM principals in the Amazon Web Services account can perform Amazon EMR cluster actions that their IAM policies allow. Whenfalse
, only the IAM principal that created the cluster and the Amazon Web Services account root user can perform Amazon EMR actions on the cluster, regardless of IAM permissions policies attached to other IAM principals.This action works on running clusters. When you create a cluster, use the RunJobFlowInputinvalid input: '$'VisibleToAllUsers parameter.
For more information, see Understanding the Amazon EMR Cluster VisibleToAllUsers Setting in the Amazon EMR Management Guide.
- Parameters:
setVisibleToAllUsersRequest
- The input to the SetVisibleToAllUsers action.- Returns:
- Result of the SetVisibleToAllUsers operation returned by the service.
- See Also:
-
setVisibleToAllUsers
default SetVisibleToAllUsersResponse setVisibleToAllUsers(Consumer<SetVisibleToAllUsersRequest.Builder> setVisibleToAllUsersRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException The SetVisibleToAllUsers parameter is no longer supported. Your cluster may be visible to all users in your account. To restrict cluster access using an IAM policy, see Identity and Access Management for Amazon EMR.
Sets the Clusterinvalid input: '$'VisibleToAllUsers value for an Amazon EMR cluster. When
true
, IAM principals in the Amazon Web Services account can perform Amazon EMR cluster actions that their IAM policies allow. Whenfalse
, only the IAM principal that created the cluster and the Amazon Web Services account root user can perform Amazon EMR actions on the cluster, regardless of IAM permissions policies attached to other IAM principals.This action works on running clusters. When you create a cluster, use the RunJobFlowInputinvalid input: '$'VisibleToAllUsers parameter.
For more information, see Understanding the Amazon EMR Cluster VisibleToAllUsers Setting in the Amazon EMR Management Guide.
This is a convenience which creates an instance of the
SetVisibleToAllUsersRequest.Builder
avoiding the need to create one manually viaSetVisibleToAllUsersRequest.builder()
- Parameters:
setVisibleToAllUsersRequest
- AConsumer
that will call methods onSetVisibleToAllUsersRequest.Builder
to create a request. The input to the SetVisibleToAllUsers action.- Returns:
- Result of the SetVisibleToAllUsers operation returned by the service.
- See Also:
-
startNotebookExecution
default StartNotebookExecutionResponse startNotebookExecution(StartNotebookExecutionRequest startNotebookExecutionRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Starts a notebook execution.
- Parameters:
startNotebookExecutionRequest
-- Returns:
- Result of the StartNotebookExecution operation returned by the service.
- See Also:
-
startNotebookExecution
default StartNotebookExecutionResponse startNotebookExecution(Consumer<StartNotebookExecutionRequest.Builder> startNotebookExecutionRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Starts a notebook execution.
This is a convenience which creates an instance of the
StartNotebookExecutionRequest.Builder
avoiding the need to create one manually viaStartNotebookExecutionRequest.builder()
- Parameters:
startNotebookExecutionRequest
- AConsumer
that will call methods onStartNotebookExecutionRequest.Builder
to create a request.- Returns:
- Result of the StartNotebookExecution operation returned by the service.
- See Also:
-
stopNotebookExecution
default StopNotebookExecutionResponse stopNotebookExecution(StopNotebookExecutionRequest stopNotebookExecutionRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Stops a notebook execution.
- Parameters:
stopNotebookExecutionRequest
-- Returns:
- Result of the StopNotebookExecution operation returned by the service.
- See Also:
-
stopNotebookExecution
default StopNotebookExecutionResponse stopNotebookExecution(Consumer<StopNotebookExecutionRequest.Builder> stopNotebookExecutionRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Stops a notebook execution.
This is a convenience which creates an instance of the
StopNotebookExecutionRequest.Builder
avoiding the need to create one manually viaStopNotebookExecutionRequest.builder()
- Parameters:
stopNotebookExecutionRequest
- AConsumer
that will call methods onStopNotebookExecutionRequest.Builder
to create a request.- Returns:
- Result of the StopNotebookExecution operation returned by the service.
- See Also:
-
terminateJobFlows
default TerminateJobFlowsResponse terminateJobFlows(TerminateJobFlowsRequest terminateJobFlowsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException TerminateJobFlows shuts a list of clusters (job flows) down. When a job flow is shut down, any step not yet completed is canceled and the Amazon EC2 instances on which the cluster is running are stopped. Any log files not already saved are uploaded to Amazon S3 if a LogUri was specified when the cluster was created.
The maximum number of clusters allowed is 10. The call to
TerminateJobFlows
is asynchronous. Depending on the configuration of the cluster, it may take up to 1-5 minutes for the cluster to completely terminate and release allocated resources, such as Amazon EC2 instances.- Parameters:
terminateJobFlowsRequest
- Input to the TerminateJobFlows operation.- Returns:
- Result of the TerminateJobFlows operation returned by the service.
- See Also:
-
terminateJobFlows
default TerminateJobFlowsResponse terminateJobFlows(Consumer<TerminateJobFlowsRequest.Builder> terminateJobFlowsRequest) throws InternalServerErrorException, AwsServiceException, SdkClientException, EmrException TerminateJobFlows shuts a list of clusters (job flows) down. When a job flow is shut down, any step not yet completed is canceled and the Amazon EC2 instances on which the cluster is running are stopped. Any log files not already saved are uploaded to Amazon S3 if a LogUri was specified when the cluster was created.
The maximum number of clusters allowed is 10. The call to
TerminateJobFlows
is asynchronous. Depending on the configuration of the cluster, it may take up to 1-5 minutes for the cluster to completely terminate and release allocated resources, such as Amazon EC2 instances.
This is a convenience which creates an instance of the
TerminateJobFlowsRequest.Builder
avoiding the need to create one manually viaTerminateJobFlowsRequest.builder()
- Parameters:
terminateJobFlowsRequest
- AConsumer
that will call methods onTerminateJobFlowsRequest.Builder
to create a request. Input to the TerminateJobFlows operation.- Returns:
- Result of the TerminateJobFlows operation returned by the service.
- See Also:
-
updateStudio
default UpdateStudioResponse updateStudio(UpdateStudioRequest updateStudioRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Updates an Amazon EMR Studio configuration, including attributes such as name, description, and subnets.
- Parameters:
updateStudioRequest
-- Returns:
- Result of the UpdateStudio operation returned by the service.
- See Also:
-
updateStudio
default UpdateStudioResponse updateStudio(Consumer<UpdateStudioRequest.Builder> updateStudioRequest) throws InternalServerException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Updates an Amazon EMR Studio configuration, including attributes such as name, description, and subnets.
This is a convenience which creates an instance of the
UpdateStudioRequest.Builder
avoiding the need to create one manually viaUpdateStudioRequest.builder()
- Parameters:
updateStudioRequest
- AConsumer
that will call methods onUpdateStudioRequest.Builder
to create a request.- Returns:
- Result of the UpdateStudio operation returned by the service.
- See Also:
-
updateStudioSessionMapping
default UpdateStudioSessionMappingResponse updateStudioSessionMapping(UpdateStudioSessionMappingRequest updateStudioSessionMappingRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Updates the session policy attached to the user or group for the specified Amazon EMR Studio.
- Parameters:
updateStudioSessionMappingRequest
-- Returns:
- Result of the UpdateStudioSessionMapping operation returned by the service.
- See Also:
-
updateStudioSessionMapping
default UpdateStudioSessionMappingResponse updateStudioSessionMapping(Consumer<UpdateStudioSessionMappingRequest.Builder> updateStudioSessionMappingRequest) throws InternalServerErrorException, InvalidRequestException, AwsServiceException, SdkClientException, EmrException Updates the session policy attached to the user or group for the specified Amazon EMR Studio.
This is a convenience which creates an instance of the
UpdateStudioSessionMappingRequest.Builder
avoiding the need to create one manually viaUpdateStudioSessionMappingRequest.builder()
- Parameters:
updateStudioSessionMappingRequest
- AConsumer
that will call methods onUpdateStudioSessionMappingRequest.Builder
to create a request.- Returns:
- Result of the UpdateStudioSessionMapping operation returned by the service.
- See Also:
-
waiter
Create an instance ofEmrWaiter
using this client.Waiters created via this method are managed by the SDK and resources will be released when the service client is closed.
- Returns:
- an instance of
EmrWaiter
-
create
Create aEmrClient
with the region loaded from theDefaultAwsRegionProviderChain
and credentials loaded from theDefaultCredentialsProvider
. -
builder
Create a builder that can be used to configure and create aEmrClient
. -
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
-