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 StringValue for looking up the service's metadata from theServiceMetadataProvider.static final String -
Method Summary
Modifier and TypeMethodDescriptiondefault AddInstanceFleetResponseaddInstanceFleet(Consumer<AddInstanceFleetRequest.Builder> addInstanceFleetRequest) Adds an instance fleet to a running cluster.default AddInstanceFleetResponseaddInstanceFleet(AddInstanceFleetRequest addInstanceFleetRequest) Adds an instance fleet to a running cluster.default AddInstanceGroupsResponseaddInstanceGroups(Consumer<AddInstanceGroupsRequest.Builder> addInstanceGroupsRequest) Adds one or more instance groups to a running cluster.default AddInstanceGroupsResponseaddInstanceGroups(AddInstanceGroupsRequest addInstanceGroupsRequest) Adds one or more instance groups to a running cluster.default AddJobFlowStepsResponseaddJobFlowSteps(Consumer<AddJobFlowStepsRequest.Builder> addJobFlowStepsRequest) AddJobFlowSteps adds new steps to a running cluster.default AddJobFlowStepsResponseaddJobFlowSteps(AddJobFlowStepsRequest addJobFlowStepsRequest) AddJobFlowSteps adds new steps to a running cluster.default AddTagsResponseaddTags(Consumer<AddTagsRequest.Builder> addTagsRequest) Adds tags to an Amazon EMR resource, such as a cluster or an Amazon EMR Studio.default AddTagsResponseaddTags(AddTagsRequest addTagsRequest) Adds tags to an Amazon EMR resource, such as a cluster or an Amazon EMR Studio.static EmrClientBuilderbuilder()Create a builder that can be used to configure and create aEmrClient.default CancelStepsResponsecancelSteps(Consumer<CancelStepsRequest.Builder> cancelStepsRequest) Cancels a pending step or steps in a running cluster.default CancelStepsResponsecancelSteps(CancelStepsRequest cancelStepsRequest) Cancels a pending step or steps in a running cluster.static EmrClientcreate()Create aEmrClientwith the region loaded from theDefaultAwsRegionProviderChainand 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 CreateStudioResponsecreateStudio(Consumer<CreateStudioRequest.Builder> createStudioRequest) Creates a new Amazon EMR Studio.default CreateStudioResponsecreateStudio(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 DeleteStudioResponsedeleteStudio(Consumer<DeleteStudioRequest.Builder> deleteStudioRequest) Removes an Amazon EMR Studio from the Studio metadata store.default DeleteStudioResponsedeleteStudio(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 DescribeClusterResponsedescribeCluster(Consumer<DescribeClusterRequest.Builder> describeClusterRequest) Provides cluster-level details including status, hardware and software configuration, VPC settings, and so on.default DescribeClusterResponsedescribeCluster(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 DescribeReleaseLabelResponsedescribeReleaseLabel(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 DescribeReleaseLabelResponsedescribeReleaseLabel(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 DescribeStepResponsedescribeStep(Consumer<DescribeStepRequest.Builder> describeStepRequest) Provides more detail about the cluster step.default DescribeStepResponsedescribeStep(DescribeStepRequest describeStepRequest) Provides more detail about the cluster step.default DescribeStudioResponsedescribeStudio(Consumer<DescribeStudioRequest.Builder> describeStudioRequest) Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio access URL, and so on.default DescribeStudioResponsedescribeStudio(DescribeStudioRequest describeStudioRequest) Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio access URL, and so on.default GetAutoTerminationPolicyResponsegetAutoTerminationPolicy(Consumer<GetAutoTerminationPolicyRequest.Builder> getAutoTerminationPolicyRequest) Returns the auto-termination policy for an Amazon EMR cluster.default GetAutoTerminationPolicyResponsegetAutoTerminationPolicy(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 GetManagedScalingPolicyResponsegetManagedScalingPolicy(Consumer<GetManagedScalingPolicyRequest.Builder> getManagedScalingPolicyRequest) Fetches the attached managed scaling policy for an Amazon EMR cluster.default GetManagedScalingPolicyResponsegetManagedScalingPolicy(GetManagedScalingPolicyRequest getManagedScalingPolicyRequest) Fetches the attached managed scaling policy for an Amazon EMR cluster.default GetStudioSessionMappingResponsegetStudioSessionMapping(Consumer<GetStudioSessionMappingRequest.Builder> getStudioSessionMappingRequest) Fetches mapping details for the specified Amazon EMR Studio and identity (user or group).default GetStudioSessionMappingResponsegetStudioSessionMapping(GetStudioSessionMappingRequest getStudioSessionMappingRequest) Fetches mapping details for the specified Amazon EMR Studio and identity (user or group).default ListBootstrapActionsResponselistBootstrapActions(Consumer<ListBootstrapActionsRequest.Builder> listBootstrapActionsRequest) Provides information about the bootstrap actions associated with a cluster.default ListBootstrapActionsResponselistBootstrapActions(ListBootstrapActionsRequest listBootstrapActionsRequest) Provides information about the bootstrap actions associated with a cluster.default ListBootstrapActionsIterablelistBootstrapActionsPaginator(Consumer<ListBootstrapActionsRequest.Builder> listBootstrapActionsRequest) This is a variant oflistBootstrapActions(software.amazon.awssdk.services.emr.model.ListBootstrapActionsRequest)operation.default ListBootstrapActionsIterablelistBootstrapActionsPaginator(ListBootstrapActionsRequest listBootstrapActionsRequest) This is a variant oflistBootstrapActions(software.amazon.awssdk.services.emr.model.ListBootstrapActionsRequest)operation.default ListClustersResponseProvides the status of all clusters visible to this Amazon Web Services account.default ListClustersResponselistClusters(Consumer<ListClustersRequest.Builder> listClustersRequest) Provides the status of all clusters visible to this Amazon Web Services account.default ListClustersResponselistClusters(ListClustersRequest listClustersRequest) Provides the status of all clusters visible to this Amazon Web Services account.default ListClustersIterableThis is a variant oflistClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)operation.default ListClustersIterablelistClustersPaginator(Consumer<ListClustersRequest.Builder> listClustersRequest) This is a variant oflistClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)operation.default ListClustersIterablelistClustersPaginator(ListClustersRequest listClustersRequest) This is a variant oflistClusters(software.amazon.awssdk.services.emr.model.ListClustersRequest)operation.default ListInstanceFleetsResponselistInstanceFleets(Consumer<ListInstanceFleetsRequest.Builder> listInstanceFleetsRequest) Lists all available details about the instance fleets in a cluster.default ListInstanceFleetsResponselistInstanceFleets(ListInstanceFleetsRequest listInstanceFleetsRequest) Lists all available details about the instance fleets in a cluster.default ListInstanceFleetsIterablelistInstanceFleetsPaginator(Consumer<ListInstanceFleetsRequest.Builder> listInstanceFleetsRequest) This is a variant oflistInstanceFleets(software.amazon.awssdk.services.emr.model.ListInstanceFleetsRequest)operation.default ListInstanceFleetsIterablelistInstanceFleetsPaginator(ListInstanceFleetsRequest listInstanceFleetsRequest) This is a variant oflistInstanceFleets(software.amazon.awssdk.services.emr.model.ListInstanceFleetsRequest)operation.default ListInstanceGroupsResponselistInstanceGroups(Consumer<ListInstanceGroupsRequest.Builder> listInstanceGroupsRequest) Provides all available details about the instance groups in a cluster.default ListInstanceGroupsResponselistInstanceGroups(ListInstanceGroupsRequest listInstanceGroupsRequest) Provides all available details about the instance groups in a cluster.default ListInstanceGroupsIterablelistInstanceGroupsPaginator(Consumer<ListInstanceGroupsRequest.Builder> listInstanceGroupsRequest) This is a variant oflistInstanceGroups(software.amazon.awssdk.services.emr.model.ListInstanceGroupsRequest)operation.default ListInstanceGroupsIterablelistInstanceGroupsPaginator(ListInstanceGroupsRequest listInstanceGroupsRequest) This is a variant oflistInstanceGroups(software.amazon.awssdk.services.emr.model.ListInstanceGroupsRequest)operation.default ListInstancesResponselistInstances(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 ListInstancesResponselistInstances(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 ListInstancesIterablelistInstancesPaginator(Consumer<ListInstancesRequest.Builder> listInstancesRequest) This is a variant oflistInstances(software.amazon.awssdk.services.emr.model.ListInstancesRequest)operation.default ListInstancesIterablelistInstancesPaginator(ListInstancesRequest listInstancesRequest) This is a variant oflistInstances(software.amazon.awssdk.services.emr.model.ListInstancesRequest)operation.default ListNotebookExecutionsResponselistNotebookExecutions(Consumer<ListNotebookExecutionsRequest.Builder> listNotebookExecutionsRequest) Provides summaries of all notebook executions.default ListNotebookExecutionsResponselistNotebookExecutions(ListNotebookExecutionsRequest listNotebookExecutionsRequest) Provides summaries of all notebook executions.default ListNotebookExecutionsIterablelistNotebookExecutionsPaginator(Consumer<ListNotebookExecutionsRequest.Builder> listNotebookExecutionsRequest) This is a variant oflistNotebookExecutions(software.amazon.awssdk.services.emr.model.ListNotebookExecutionsRequest)operation.default ListNotebookExecutionsIterablelistNotebookExecutionsPaginator(ListNotebookExecutionsRequest listNotebookExecutionsRequest) This is a variant oflistNotebookExecutions(software.amazon.awssdk.services.emr.model.ListNotebookExecutionsRequest)operation.default ListReleaseLabelsResponselistReleaseLabels(Consumer<ListReleaseLabelsRequest.Builder> listReleaseLabelsRequest) Retrieves release labels of Amazon EMR services in the Region where the API is called.default ListReleaseLabelsResponselistReleaseLabels(ListReleaseLabelsRequest listReleaseLabelsRequest) Retrieves release labels of Amazon EMR services in the Region where the API is called.default ListReleaseLabelsIterablelistReleaseLabelsPaginator(Consumer<ListReleaseLabelsRequest.Builder> listReleaseLabelsRequest) This is a variant oflistReleaseLabels(software.amazon.awssdk.services.emr.model.ListReleaseLabelsRequest)operation.default ListReleaseLabelsIterablelistReleaseLabelsPaginator(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 ListStepsResponselistSteps(Consumer<ListStepsRequest.Builder> listStepsRequest) Provides a list of steps for the cluster in reverse order unless you specifystepIdswith the request or filter byStepStates.default ListStepsResponselistSteps(ListStepsRequest listStepsRequest) Provides a list of steps for the cluster in reverse order unless you specifystepIdswith the request or filter byStepStates.default ListStepsIterablelistStepsPaginator(Consumer<ListStepsRequest.Builder> listStepsRequest) This is a variant oflistSteps(software.amazon.awssdk.services.emr.model.ListStepsRequest)operation.default ListStepsIterablelistStepsPaginator(ListStepsRequest listStepsRequest) This is a variant oflistSteps(software.amazon.awssdk.services.emr.model.ListStepsRequest)operation.default ListStudiosResponselistStudios(Consumer<ListStudiosRequest.Builder> listStudiosRequest) Returns a list of all Amazon EMR Studios associated with the Amazon Web Services account.default ListStudiosResponselistStudios(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 ListStudiosIterablelistStudiosPaginator(Consumer<ListStudiosRequest.Builder> listStudiosRequest) This is a variant oflistStudios(software.amazon.awssdk.services.emr.model.ListStudiosRequest)operation.default ListStudiosIterablelistStudiosPaginator(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 ModifyClusterResponsemodifyCluster(Consumer<ModifyClusterRequest.Builder> modifyClusterRequest) Modifies the number of steps that can be executed concurrently for the cluster specified using ClusterID.default ModifyClusterResponsemodifyCluster(ModifyClusterRequest modifyClusterRequest) Modifies the number of steps that can be executed concurrently for the cluster specified using ClusterID.default ModifyInstanceFleetResponsemodifyInstanceFleet(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 ModifyInstanceFleetResponsemodifyInstanceFleet(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 ModifyInstanceGroupsResponsemodifyInstanceGroups(Consumer<ModifyInstanceGroupsRequest.Builder> modifyInstanceGroupsRequest) ModifyInstanceGroups modifies the number of nodes and configuration settings of an instance group.default ModifyInstanceGroupsResponsemodifyInstanceGroups(ModifyInstanceGroupsRequest modifyInstanceGroupsRequest) ModifyInstanceGroups modifies the number of nodes and configuration settings of an instance group.default PutAutoScalingPolicyResponseputAutoScalingPolicy(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 PutAutoScalingPolicyResponseputAutoScalingPolicy(PutAutoScalingPolicyRequest putAutoScalingPolicyRequest) Creates or updates an automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster.default PutAutoTerminationPolicyResponseputAutoTerminationPolicy(Consumer<PutAutoTerminationPolicyRequest.Builder> putAutoTerminationPolicyRequest) default PutAutoTerminationPolicyResponseputAutoTerminationPolicy(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 PutManagedScalingPolicyResponseputManagedScalingPolicy(Consumer<PutManagedScalingPolicyRequest.Builder> putManagedScalingPolicyRequest) Creates or updates a managed scaling policy for an Amazon EMR cluster.default PutManagedScalingPolicyResponseputManagedScalingPolicy(PutManagedScalingPolicyRequest putManagedScalingPolicyRequest) Creates or updates a managed scaling policy for an Amazon EMR cluster.default RemoveAutoScalingPolicyResponseremoveAutoScalingPolicy(Consumer<RemoveAutoScalingPolicyRequest.Builder> removeAutoScalingPolicyRequest) Removes an automatic scaling policy from a specified instance group within an Amazon EMR cluster.default RemoveAutoScalingPolicyResponseremoveAutoScalingPolicy(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 RemoveTagsResponseremoveTags(Consumer<RemoveTagsRequest.Builder> removeTagsRequest) Removes tags from an Amazon EMR resource, such as a cluster or Amazon EMR Studio.default RemoveTagsResponseremoveTags(RemoveTagsRequest removeTagsRequest) Removes tags from an Amazon EMR resource, such as a cluster or Amazon EMR Studio.default RunJobFlowResponserunJobFlow(Consumer<RunJobFlowRequest.Builder> runJobFlowRequest) RunJobFlow creates and starts running a new cluster (job flow).default RunJobFlowResponserunJobFlow(RunJobFlowRequest runJobFlowRequest) RunJobFlow creates and starts running a new cluster (job flow).default EmrServiceClientConfigurationThe SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfigurationstatic ServiceMetadatasetKeepJobFlowAliveWhenNoSteps(Consumer<SetKeepJobFlowAliveWhenNoStepsRequest.Builder> setKeepJobFlowAliveWhenNoStepsRequest) You can use theSetKeepJobFlowAliveWhenNoStepsto configure a cluster (job flow) to terminate after the step execution, i.e., all your steps are executed.setKeepJobFlowAliveWhenNoSteps(SetKeepJobFlowAliveWhenNoStepsRequest setKeepJobFlowAliveWhenNoStepsRequest) You can use theSetKeepJobFlowAliveWhenNoStepsto configure a cluster (job flow) to terminate after the step execution, i.e., all your steps are executed.default SetTerminationProtectionResponsesetTerminationProtection(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 SetTerminationProtectionResponsesetTerminationProtection(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 SetVisibleToAllUsersResponsesetVisibleToAllUsers(Consumer<SetVisibleToAllUsersRequest.Builder> setVisibleToAllUsersRequest) default SetVisibleToAllUsersResponsesetVisibleToAllUsers(SetVisibleToAllUsersRequest setVisibleToAllUsersRequest) default StartNotebookExecutionResponsestartNotebookExecution(Consumer<StartNotebookExecutionRequest.Builder> startNotebookExecutionRequest) Starts a notebook execution.default StartNotebookExecutionResponsestartNotebookExecution(StartNotebookExecutionRequest startNotebookExecutionRequest) Starts a notebook execution.default StopNotebookExecutionResponsestopNotebookExecution(Consumer<StopNotebookExecutionRequest.Builder> stopNotebookExecutionRequest) Stops a notebook execution.default StopNotebookExecutionResponsestopNotebookExecution(StopNotebookExecutionRequest stopNotebookExecutionRequest) Stops a notebook execution.default TerminateJobFlowsResponseterminateJobFlows(Consumer<TerminateJobFlowsRequest.Builder> terminateJobFlowsRequest) TerminateJobFlows shuts a list of clusters (job flows) down.default TerminateJobFlowsResponseterminateJobFlows(TerminateJobFlowsRequest terminateJobFlowsRequest) TerminateJobFlows shuts a list of clusters (job flows) down.default UpdateStudioResponseupdateStudio(Consumer<UpdateStudioRequest.Builder> updateStudioRequest) Updates an Amazon EMR Studio configuration, including attributes such as name, description, and subnets.default UpdateStudioResponseupdateStudio(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 EmrWaiterwaiter()Create an instance ofEmrWaiterusing this client.Methods inherited from interface software.amazon.awssdk.utils.SdkAutoCloseable
closeMethods 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.Builderavoiding the need to create one manually viaAddInstanceFleetRequest.builder()- Parameters:
addInstanceFleetRequest- AConsumerthat will call methods onAddInstanceFleetRequest.Builderto 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.Builderavoiding the need to create one manually viaAddInstanceGroupsRequest.builder()- Parameters:
addInstanceGroupsRequest- AConsumerthat will call methods onAddInstanceGroupsRequest.Builderto 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
HadoopJarStepobject 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
HadoopJarStepobject cannot exceed a total of 10240 characters.
This is a convenience which creates an instance of the
AddJobFlowStepsRequest.Builderavoiding the need to create one manually viaAddJobFlowStepsRequest.builder()- Parameters:
addJobFlowStepsRequest- AConsumerthat will call methods onAddJobFlowStepsRequest.Builderto 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.Builderavoiding the need to create one manually viaAddTagsRequest.builder()- Parameters:
addTagsRequest- AConsumerthat will call methods onAddTagsRequest.Builderto 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
PENDINGorRUNNINGstate. In earlier versions of Amazon EMR, you can only cancel steps that are in aPENDINGstate.- 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
PENDINGorRUNNINGstate. In earlier versions of Amazon EMR, you can only cancel steps that are in aPENDINGstate.
This is a convenience which creates an instance of the
CancelStepsRequest.Builderavoiding the need to create one manually viaCancelStepsRequest.builder()- Parameters:
cancelStepsRequest- AConsumerthat will call methods onCancelStepsRequest.Builderto 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.Builderavoiding the need to create one manually viaCreateSecurityConfigurationRequest.builder()- Parameters:
createSecurityConfigurationRequest- AConsumerthat will call methods onCreateSecurityConfigurationRequest.Builderto 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.Builderavoiding the need to create one manually viaCreateStudioRequest.builder()- Parameters:
createStudioRequest- AConsumerthat will call methods onCreateStudioRequest.Builderto 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. UseCreateStudioSessionMappingto 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. UseCreateStudioSessionMappingto 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.Builderavoiding the need to create one manually viaCreateStudioSessionMappingRequest.builder()- Parameters:
createStudioSessionMappingRequest- AConsumerthat will call methods onCreateStudioSessionMappingRequest.Builderto 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.Builderavoiding the need to create one manually viaDeleteSecurityConfigurationRequest.builder()- Parameters:
deleteSecurityConfigurationRequest- AConsumerthat will call methods onDeleteSecurityConfigurationRequest.Builderto 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.Builderavoiding the need to create one manually viaDeleteStudioRequest.builder()- Parameters:
deleteStudioRequest- AConsumerthat will call methods onDeleteStudioRequest.Builderto 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.Builderavoiding the need to create one manually viaDeleteStudioSessionMappingRequest.builder()- Parameters:
deleteStudioSessionMappingRequest- AConsumerthat will call methods onDeleteStudioSessionMappingRequest.Builderto 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.Builderavoiding the need to create one manually viaDescribeClusterRequest.builder()- Parameters:
describeClusterRequest- AConsumerthat will call methods onDescribeClusterRequest.Builderto 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.Builderavoiding the need to create one manually viaDescribeNotebookExecutionRequest.builder()- Parameters:
describeNotebookExecutionRequest- AConsumerthat will call methods onDescribeNotebookExecutionRequest.Builderto 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.Builderavoiding the need to create one manually viaDescribeReleaseLabelRequest.builder()- Parameters:
describeReleaseLabelRequest- AConsumerthat will call methods onDescribeReleaseLabelRequest.Builderto 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.Builderavoiding the need to create one manually viaDescribeSecurityConfigurationRequest.builder()- Parameters:
describeSecurityConfigurationRequest- AConsumerthat will call methods onDescribeSecurityConfigurationRequest.Builderto 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.Builderavoiding the need to create one manually viaDescribeStepRequest.builder()- Parameters:
describeStepRequest- AConsumerthat will call methods onDescribeStepRequest.Builderto 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.Builderavoiding the need to create one manually viaDescribeStudioRequest.builder()- Parameters:
describeStudioRequest- AConsumerthat will call methods onDescribeStudioRequest.Builderto 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.Builderavoiding the need to create one manually viaGetAutoTerminationPolicyRequest.builder()- Parameters:
getAutoTerminationPolicyRequest- AConsumerthat will call methods onGetAutoTerminationPolicyRequest.Builderto 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.Builderavoiding the need to create one manually viaGetBlockPublicAccessConfigurationRequest.builder()- Parameters:
getBlockPublicAccessConfigurationRequest- AConsumerthat will call methods onGetBlockPublicAccessConfigurationRequest.Builderto 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.Builderavoiding the need to create one manually viaGetClusterSessionCredentialsRequest.builder()- Parameters:
getClusterSessionCredentialsRequest- AConsumerthat will call methods onGetClusterSessionCredentialsRequest.Builderto 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.Builderavoiding the need to create one manually viaGetManagedScalingPolicyRequest.builder()- Parameters:
getManagedScalingPolicyRequest- AConsumerthat will call methods onGetManagedScalingPolicyRequest.Builderto 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.Builderavoiding the need to create one manually viaGetStudioSessionMappingRequest.builder()- Parameters:
getStudioSessionMappingRequest- AConsumerthat will call methods onGetStudioSessionMappingRequest.Builderto 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.Builderavoiding the need to create one manually viaListBootstrapActionsRequest.builder()- Parameters:
listBootstrapActionsRequest- AConsumerthat will call methods onListBootstrapActionsRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListBootstrapActionsRequest.builder()- Parameters:
listBootstrapActionsRequest- AConsumerthat will call methods onListBootstrapActionsRequest.Builderto 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.Builderavoiding the need to create one manually viaListClustersRequest.builder()- Parameters:
listClustersRequest- AConsumerthat will call methods onListClustersRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListClustersRequest.builder()- Parameters:
listClustersRequest- AConsumerthat will call methods onListClustersRequest.Builderto 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.Builderavoiding the need to create one manually viaListInstanceFleetsRequest.builder()- Parameters:
listInstanceFleetsRequest- AConsumerthat will call methods onListInstanceFleetsRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListInstanceFleetsRequest.builder()- Parameters:
listInstanceFleetsRequest- AConsumerthat will call methods onListInstanceFleetsRequest.Builderto 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.Builderavoiding the need to create one manually viaListInstanceGroupsRequest.builder()- Parameters:
listInstanceGroupsRequest- AConsumerthat will call methods onListInstanceGroupsRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListInstanceGroupsRequest.builder()- Parameters:
listInstanceGroupsRequest- AConsumerthat will call methods onListInstanceGroupsRequest.Builderto 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.Builderavoiding the need to create one manually viaListInstancesRequest.builder()- Parameters:
listInstancesRequest- AConsumerthat will call methods onListInstancesRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListInstancesRequest.builder()- Parameters:
listInstancesRequest- AConsumerthat will call methods onListInstancesRequest.Builderto 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
ListNotebookExecutionscalls.- 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
ListNotebookExecutionscalls.
This is a convenience which creates an instance of the
ListNotebookExecutionsRequest.Builderavoiding the need to create one manually viaListNotebookExecutionsRequest.builder()- Parameters:
listNotebookExecutionsRequest- AConsumerthat will call methods onListNotebookExecutionsRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListNotebookExecutionsRequest.builder()- Parameters:
listNotebookExecutionsRequest- AConsumerthat will call methods onListNotebookExecutionsRequest.Builderto 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.Builderavoiding the need to create one manually viaListReleaseLabelsRequest.builder()- Parameters:
listReleaseLabelsRequest- AConsumerthat will call methods onListReleaseLabelsRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListReleaseLabelsRequest.builder()- Parameters:
listReleaseLabelsRequest- AConsumerthat will call methods onListReleaseLabelsRequest.Builderto 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.Builderavoiding the need to create one manually viaListSecurityConfigurationsRequest.builder()- Parameters:
listSecurityConfigurationsRequest- AConsumerthat will call methods onListSecurityConfigurationsRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListSecurityConfigurationsRequest.builder()- Parameters:
listSecurityConfigurationsRequest- AConsumerthat will call methods onListSecurityConfigurationsRequest.Builderto 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
stepIdswith 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
stepIdswith 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.Builderavoiding the need to create one manually viaListStepsRequest.builder()- Parameters:
listStepsRequest- AConsumerthat will call methods onListStepsRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListStepsRequest.builder()- Parameters:
listStepsRequest- AConsumerthat will call methods onListStepsRequest.Builderto 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.Builderavoiding the need to create one manually viaListStudioSessionMappingsRequest.builder()- Parameters:
listStudioSessionMappingsRequest- AConsumerthat will call methods onListStudioSessionMappingsRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListStudioSessionMappingsRequest.builder()- Parameters:
listStudioSessionMappingsRequest- AConsumerthat will call methods onListStudioSessionMappingsRequest.Builderto 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.Builderavoiding the need to create one manually viaListStudiosRequest.builder()- Parameters:
listStudiosRequest- AConsumerthat will call methods onListStudiosRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListStudiosRequest.builder()- Parameters:
listStudiosRequest- AConsumerthat will call methods onListStudiosRequest.Builderto 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.Builderavoiding the need to create one manually viaListSupportedInstanceTypesRequest.builder()- Parameters:
listSupportedInstanceTypesRequest- AConsumerthat will call methods onListSupportedInstanceTypesRequest.Builderto 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 Stream
2) Using For loopsoftware.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 Stream
2) Using For loopsoftware.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.Builderavoiding the need to create one manually viaListSupportedInstanceTypesRequest.builder()- Parameters:
listSupportedInstanceTypesRequest- AConsumerthat will call methods onListSupportedInstanceTypesRequest.Builderto 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.Builderavoiding the need to create one manually viaModifyClusterRequest.builder()- Parameters:
modifyClusterRequest- AConsumerthat will call methods onModifyClusterRequest.Builderto 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.Builderavoiding the need to create one manually viaModifyInstanceFleetRequest.builder()- Parameters:
modifyInstanceFleetRequest- AConsumerthat will call methods onModifyInstanceFleetRequest.Builderto 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.Builderavoiding the need to create one manually viaModifyInstanceGroupsRequest.builder()- Parameters:
modifyInstanceGroupsRequest- AConsumerthat will call methods onModifyInstanceGroupsRequest.Builderto 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.Builderavoiding the need to create one manually viaPutAutoScalingPolicyRequest.builder()- Parameters:
putAutoScalingPolicyRequest- AConsumerthat will call methods onPutAutoScalingPolicyRequest.Builderto 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.Builderavoiding the need to create one manually viaPutAutoTerminationPolicyRequest.builder()- Parameters:
putAutoTerminationPolicyRequest- AConsumerthat will call methods onPutAutoTerminationPolicyRequest.Builderto 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.Builderavoiding the need to create one manually viaPutBlockPublicAccessConfigurationRequest.builder()- Parameters:
putBlockPublicAccessConfigurationRequest- AConsumerthat will call methods onPutBlockPublicAccessConfigurationRequest.Builderto 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.Builderavoiding the need to create one manually viaPutManagedScalingPolicyRequest.builder()- Parameters:
putManagedScalingPolicyRequest- AConsumerthat will call methods onPutManagedScalingPolicyRequest.Builderto 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.Builderavoiding the need to create one manually viaRemoveAutoScalingPolicyRequest.builder()- Parameters:
removeAutoScalingPolicyRequest- AConsumerthat will call methods onRemoveAutoScalingPolicyRequest.Builderto 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.Builderavoiding the need to create one manually viaRemoveAutoTerminationPolicyRequest.builder()- Parameters:
removeAutoTerminationPolicyRequest- AConsumerthat will call methods onRemoveAutoTerminationPolicyRequest.Builderto 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.Builderavoiding the need to create one manually viaRemoveManagedScalingPolicyRequest.builder()- Parameters:
removeManagedScalingPolicyRequest- AConsumerthat will call methods onRemoveManagedScalingPolicyRequest.Builderto 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.Builderavoiding the need to create one manually viaRemoveTagsRequest.builder()- Parameters:
removeTagsRequest- AConsumerthat will call methods onRemoveTagsRequest.Builderto 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
KeepJobFlowAliveWhenNoStepsparameter 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
TerminationProtectedparameter toTRUEto 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
KeepJobFlowAliveWhenNoStepsparameter 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
TerminationProtectedparameter toTRUEto 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.Builderavoiding the need to create one manually viaRunJobFlowRequest.builder()- Parameters:
runJobFlowRequest- AConsumerthat will call methods onRunJobFlowRequest.Builderto 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
SetKeepJobFlowAliveWhenNoStepsto 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 configureSetKeepJobFlowAliveWhenNoStepsto false. If you want a long running cluster, configureSetKeepJobFlowAliveWhenNoStepsto 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
SetKeepJobFlowAliveWhenNoStepsto 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 configureSetKeepJobFlowAliveWhenNoStepsto false. If you want a long running cluster, configureSetKeepJobFlowAliveWhenNoStepsto 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.Builderavoiding the need to create one manually viaSetKeepJobFlowAliveWhenNoStepsRequest.builder()- Parameters:
setKeepJobFlowAliveWhenNoStepsRequest- AConsumerthat will call methods onSetKeepJobFlowAliveWhenNoStepsRequest.Builderto 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
SetTerminationProtectionon a cluster is similar to calling the Amazon EC2DisableAPITerminationAPI on all Amazon EC2 instances in a cluster.SetTerminationProtectionis 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
SetTerminationProtectiontotrue, you must first unlock the job flow by a subsequent call toSetTerminationProtectionin 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
SetTerminationProtectionon a cluster is similar to calling the Amazon EC2DisableAPITerminationAPI on all Amazon EC2 instances in a cluster.SetTerminationProtectionis 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
SetTerminationProtectiontotrue, you must first unlock the job flow by a subsequent call toSetTerminationProtectionin 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.Builderavoiding the need to create one manually viaSetTerminationProtectionRequest.builder()- Parameters:
setTerminationProtectionRequest- AConsumerthat will call methods onSetTerminationProtectionRequest.Builderto 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
TerminationProtectedare 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
TerminationProtectedare 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.Builderavoiding the need to create one manually viaSetUnhealthyNodeReplacementRequest.builder()- Parameters:
setUnhealthyNodeReplacementRequest- AConsumerthat will call methods onSetUnhealthyNodeReplacementRequest.Builderto 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.Builderavoiding the need to create one manually viaSetVisibleToAllUsersRequest.builder()- Parameters:
setVisibleToAllUsersRequest- AConsumerthat will call methods onSetVisibleToAllUsersRequest.Builderto 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.Builderavoiding the need to create one manually viaStartNotebookExecutionRequest.builder()- Parameters:
startNotebookExecutionRequest- AConsumerthat will call methods onStartNotebookExecutionRequest.Builderto 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.Builderavoiding the need to create one manually viaStopNotebookExecutionRequest.builder()- Parameters:
stopNotebookExecutionRequest- AConsumerthat will call methods onStopNotebookExecutionRequest.Builderto 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
TerminateJobFlowsis 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
TerminateJobFlowsis 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.Builderavoiding the need to create one manually viaTerminateJobFlowsRequest.builder()- Parameters:
terminateJobFlowsRequest- AConsumerthat will call methods onTerminateJobFlowsRequest.Builderto 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.Builderavoiding the need to create one manually viaUpdateStudioRequest.builder()- Parameters:
updateStudioRequest- AConsumerthat will call methods onUpdateStudioRequest.Builderto 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.Builderavoiding the need to create one manually viaUpdateStudioSessionMappingRequest.builder()- Parameters:
updateStudioSessionMappingRequest- AConsumerthat will call methods onUpdateStudioSessionMappingRequest.Builderto create a request.- Returns:
- Result of the UpdateStudioSessionMapping operation returned by the service.
- See Also:
-
waiter
-
create
Create aEmrClientwith the region loaded from theDefaultAwsRegionProviderChainand credentials loaded from theDefaultCredentialsProvider. -
builder
Create a builder that can be used to configure and create aEmrClient. -
serviceMetadata
-
serviceClientConfiguration
Description copied from interface:SdkClientThe SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfiguration- Specified by:
serviceClientConfigurationin interfaceAwsClient- Specified by:
serviceClientConfigurationin interfaceSdkClient- Returns:
- SdkServiceClientConfiguration
-