Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
   /*
    * Copyright 2010-2015 Amazon.com, Inc. or its affiliates. All Rights Reserved.
    * 
    * Licensed under the Apache License, Version 2.0 (the "License").
    * You may not use this file except in compliance with the License.
    * A copy of the License is located at
    * 
    *  http://aws.amazon.com/apache2.0
    * 
   * or in the "license" file accompanying this file. This file is distributed
   * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
   * express or implied. See the License for the specific language governing
   * permissions and limitations under the License.
   */
  package com.amazonaws.services.elasticmapreduce.model;
  
  
Container for the parameters to the RunJobFlow operation.

RunJobFlow creates and starts running a new job flow. The job flow will run the steps specified. Once the job flow completes, the cluster is stopped and the HDFS partition is lost. To prevent loss of data, configure the last step of the job flow to store results in Amazon S3. If the JobFlowInstancesConfig KeepJobFlowAliveWhenNoSteps parameter is set to TRUE , the job flow will transition to the WAITING state rather than shutting down once the steps have completed.

For additional protection, you can set the JobFlowInstancesConfig TerminationProtected parameter to TRUE to lock the job flow 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 job flow 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 more information on how to do this, go to Add More than 256 Steps to a Job Flow in the Amazon Elastic MapReduce Developer's Guide .

For long running job flows, we recommend that you periodically store your results.

  
  public class RunJobFlowRequest extends AmazonWebServiceRequest implements SerializableCloneable {

    
The name of the job flow.

Constraints:
Length: 0 - 256
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

  
      private String name;

    
The location in Amazon S3 to write the log files of the job flow. If a value is not provided, logs are not created.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

  
      private String logUri;

    
A JSON string for selecting additional features.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

  
      private String additionalInfo;

    
The version of the Amazon Machine Image (AMI) to use when launching Amazon EC2 instances in the job flow. The following values are valid:
  • "latest" (uses the latest AMI)
  • The version number of the AMI to use, for example, "2.0"

If the AMI supports multiple versions of Hadoop (for example, AMI 1.0 supports both Hadoop 0.18 and 0.20) you can use the JobFlowInstancesConfig HadoopVersion parameter to modify the version of Hadoop from the defaults shown above.

For details about the AMI versions currently supported by Amazon Elastic MapReduce, go to AMI Versions Supported in Elastic MapReduce in the Amazon Elastic MapReduce Developer's Guide.

Constraints:
Length: 0 - 256
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

 
     private String amiVersion;

    
A specification of the number and type of Amazon EC2 instances on which to run the job flow.
 
     private JobFlowInstancesConfig instances;

    
A list of steps to be executed by the job flow.
 
A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.
 
A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
 
A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.
 
Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.
 
     private Boolean visibleToAllUsers;

    
An IAM role for the job flow. The EC2 instances of the job flow assume this role. The default role is EMRJobflowDefault. In order to use the default role, you must have already created it using the CLI.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

 
     private String jobFlowRole;

    
The IAM role that will be assumed by the Amazon EMR service to access AWS resources on your behalf.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

 
     private String serviceRole;

    
A list of tags to associate with a cluster and propagate to Amazon EC2 instances.
 
Default constructor for a new RunJobFlowRequest object. Callers should use the setter or fluent setter (with...) methods to initialize this object after creating it.
 
     public RunJobFlowRequest() {}
    
    
Constructs a new RunJobFlowRequest object. Callers should use the setter or fluent setter (with...) methods to initialize any additional object members.

Parameters:
name The name of the job flow.
instances A specification of the number and type of Amazon EC2 instances on which to run the job flow.
 
     public RunJobFlowRequest(String nameJobFlowInstancesConfig instances) {
         setName(name);
         setInstances(instances);
     }

    
The name of the job flow.

Constraints:
Length: 0 - 256
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Returns:
The name of the job flow.
 
     public String getName() {
         return ;
     }
    
    
The name of the job flow.

Constraints:
Length: 0 - 256
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
name The name of the job flow.
 
     public void setName(String name) {
         this. = name;
     }
    
    
The name of the job flow.

Returns a reference to this object so that method calls can be chained together.

Constraints:
Length: 0 - 256
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
name The name of the job flow.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withName(String name) {
         this. = name;
         return this;
     }

    
The location in Amazon S3 to write the log files of the job flow. If a value is not provided, logs are not created.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Returns:
The location in Amazon S3 to write the log files of the job flow. If a value is not provided, logs are not created.
 
     public String getLogUri() {
         return ;
     }
    
    
The location in Amazon S3 to write the log files of the job flow. If a value is not provided, logs are not created.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
logUri The location in Amazon S3 to write the log files of the job flow. If a value is not provided, logs are not created.
 
     public void setLogUri(String logUri) {
         this. = logUri;
     }
    
    
The location in Amazon S3 to write the log files of the job flow. If a value is not provided, logs are not created.

Returns a reference to this object so that method calls can be chained together.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
logUri The location in Amazon S3 to write the log files of the job flow. If a value is not provided, logs are not created.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withLogUri(String logUri) {
         this. = logUri;
         return this;
     }

    
A JSON string for selecting additional features.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Returns:
A JSON string for selecting additional features.
 
     public String getAdditionalInfo() {
         return ;
     }
    
    
A JSON string for selecting additional features.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
additionalInfo A JSON string for selecting additional features.
 
     public void setAdditionalInfo(String additionalInfo) {
         this. = additionalInfo;
     }
    
    
A JSON string for selecting additional features.

Returns a reference to this object so that method calls can be chained together.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
additionalInfo A JSON string for selecting additional features.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withAdditionalInfo(String additionalInfo) {
         this. = additionalInfo;
         return this;
     }

    
The version of the Amazon Machine Image (AMI) to use when launching Amazon EC2 instances in the job flow. The following values are valid:
  • "latest" (uses the latest AMI)
  • The version number of the AMI to use, for example, "2.0"

If the AMI supports multiple versions of Hadoop (for example, AMI 1.0 supports both Hadoop 0.18 and 0.20) you can use the JobFlowInstancesConfig HadoopVersion parameter to modify the version of Hadoop from the defaults shown above.

For details about the AMI versions currently supported by Amazon Elastic MapReduce, go to AMI Versions Supported in Elastic MapReduce in the Amazon Elastic MapReduce Developer's Guide.

Constraints:
Length: 0 - 256
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Returns:
The version of the Amazon Machine Image (AMI) to use when launching Amazon EC2 instances in the job flow. The following values are valid:
  • "latest" (uses the latest AMI)
  • The version number of the AMI to use, for example, "2.0"

If the AMI supports multiple versions of Hadoop (for example, AMI 1.0 supports both Hadoop 0.18 and 0.20) you can use the JobFlowInstancesConfig HadoopVersion parameter to modify the version of Hadoop from the defaults shown above.

For details about the AMI versions currently supported by Amazon Elastic MapReduce, go to AMI Versions Supported in Elastic MapReduce in the Amazon Elastic MapReduce Developer's Guide.

 
     public String getAmiVersion() {
         return ;
     }
    
    
The version of the Amazon Machine Image (AMI) to use when launching Amazon EC2 instances in the job flow. The following values are valid:
  • "latest" (uses the latest AMI)
  • The version number of the AMI to use, for example, "2.0"

If the AMI supports multiple versions of Hadoop (for example, AMI 1.0 supports both Hadoop 0.18 and 0.20) you can use the JobFlowInstancesConfig HadoopVersion parameter to modify the version of Hadoop from the defaults shown above.

For details about the AMI versions currently supported by Amazon Elastic MapReduce, go to AMI Versions Supported in Elastic MapReduce in the Amazon Elastic MapReduce Developer's Guide.

Constraints:
Length: 0 - 256
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
amiVersion The version of the Amazon Machine Image (AMI) to use when launching Amazon EC2 instances in the job flow. The following values are valid:
  • "latest" (uses the latest AMI)
  • The version number of the AMI to use, for example, "2.0"

If the AMI supports multiple versions of Hadoop (for example, AMI 1.0 supports both Hadoop 0.18 and 0.20) you can use the JobFlowInstancesConfig HadoopVersion parameter to modify the version of Hadoop from the defaults shown above.

For details about the AMI versions currently supported by Amazon Elastic MapReduce, go to AMI Versions Supported in Elastic MapReduce in the Amazon Elastic MapReduce Developer's Guide.

 
     public void setAmiVersion(String amiVersion) {
         this. = amiVersion;
     }
    
    
The version of the Amazon Machine Image (AMI) to use when launching Amazon EC2 instances in the job flow. The following values are valid:
  • "latest" (uses the latest AMI)
  • The version number of the AMI to use, for example, "2.0"

If the AMI supports multiple versions of Hadoop (for example, AMI 1.0 supports both Hadoop 0.18 and 0.20) you can use the JobFlowInstancesConfig HadoopVersion parameter to modify the version of Hadoop from the defaults shown above.

For details about the AMI versions currently supported by Amazon Elastic MapReduce, go to AMI Versions Supported in Elastic MapReduce in the Amazon Elastic MapReduce Developer's Guide.

Returns a reference to this object so that method calls can be chained together.

Constraints:
Length: 0 - 256
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
amiVersion The version of the Amazon Machine Image (AMI) to use when launching Amazon EC2 instances in the job flow. The following values are valid:
  • "latest" (uses the latest AMI)
  • The version number of the AMI to use, for example, "2.0"

If the AMI supports multiple versions of Hadoop (for example, AMI 1.0 supports both Hadoop 0.18 and 0.20) you can use the JobFlowInstancesConfig HadoopVersion parameter to modify the version of Hadoop from the defaults shown above.

For details about the AMI versions currently supported by Amazon Elastic MapReduce, go to AMI Versions Supported in Elastic MapReduce in the Amazon Elastic MapReduce Developer's Guide.

Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withAmiVersion(String amiVersion) {
         this. = amiVersion;
         return this;
     }

    
A specification of the number and type of Amazon EC2 instances on which to run the job flow.

Returns:
A specification of the number and type of Amazon EC2 instances on which to run the job flow.
 
     public JobFlowInstancesConfig getInstances() {
         return ;
     }
    
    
A specification of the number and type of Amazon EC2 instances on which to run the job flow.

Parameters:
instances A specification of the number and type of Amazon EC2 instances on which to run the job flow.
 
     public void setInstances(JobFlowInstancesConfig instances) {
         this. = instances;
     }
    
    
A specification of the number and type of Amazon EC2 instances on which to run the job flow.

Returns a reference to this object so that method calls can be chained together.

Parameters:
instances A specification of the number and type of Amazon EC2 instances on which to run the job flow.
Returns:
A reference to this updated object so that method calls can be chained together.
 
         this. = instances;
         return this;
     }

    
A list of steps to be executed by the job flow.

Returns:
A list of steps to be executed by the job flow.
 
     public java.util.List<StepConfiggetSteps() {
         if ( == null) {
                = new com.amazonaws.internal.ListWithAutoConstructFlag<StepConfig>();
               .setAutoConstruct(true);
         }
         return ;
     }
    
    
A list of steps to be executed by the job flow.

Parameters:
steps A list of steps to be executed by the job flow.
 
     public void setSteps(java.util.Collection<StepConfigsteps) {
         if (steps == null) {
             this. = null;
             return;
         }
         stepsCopy.addAll(steps);
         this. = stepsCopy;
     }
    
    
A list of steps to be executed by the job flow.

NOTE: This method appends the values to the existing list (if any). Use setSteps(java.util.Collection) or withSteps(java.util.Collection) if you want to override the existing values.

Returns a reference to this object so that method calls can be chained together.

Parameters:
steps A list of steps to be executed by the job flow.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withSteps(StepConfig... steps) {
         if (getSteps() == nullsetSteps(new java.util.ArrayList<StepConfig>(steps.length));
         for (StepConfig value : steps) {
             getSteps().add(value);
         }
         return this;
     }
    
    
A list of steps to be executed by the job flow.

Returns a reference to this object so that method calls can be chained together.

Parameters:
steps A list of steps to be executed by the job flow.
Returns:
A reference to this updated object so that method calls can be chained together.
 
         if (steps == null) {
             this. = null;
         } else {
             stepsCopy.addAll(steps);
             this. = stepsCopy;
         }
 
         return this;
     }

    
A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.

Returns:
A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.
 
         if ( == null) {
               .setAutoConstruct(true);
         }
         return ;
     }
    
    
A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.

Parameters:
bootstrapActions A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.
 
     public void setBootstrapActions(java.util.Collection<BootstrapActionConfigbootstrapActions) {
         if (bootstrapActions == null) {
             this. = null;
             return;
         }
         bootstrapActionsCopy.addAll(bootstrapActions);
         this. = bootstrapActionsCopy;
     }
    
    
A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.

NOTE: This method appends the values to the existing list (if any). Use setBootstrapActions(java.util.Collection) or withBootstrapActions(java.util.Collection) if you want to override the existing values.

Returns a reference to this object so that method calls can be chained together.

Parameters:
bootstrapActions A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withBootstrapActions(BootstrapActionConfig... bootstrapActions) {
         if (getBootstrapActions() == nullsetBootstrapActions(new java.util.ArrayList<BootstrapActionConfig>(bootstrapActions.length));
         for (BootstrapActionConfig value : bootstrapActions) {
             getBootstrapActions().add(value);
         }
         return this;
     }
    
    
A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.

Returns a reference to this object so that method calls can be chained together.

Parameters:
bootstrapActions A list of bootstrap actions that will be run before Hadoop is started on the cluster nodes.
Returns:
A reference to this updated object so that method calls can be chained together.
 
         if (bootstrapActions == null) {
             this. = null;
         } else {
             bootstrapActionsCopy.addAll(bootstrapActions);
             this. = bootstrapActionsCopy;
         }
 
         return this;
     }

    
A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.

Returns:
A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
 
     public java.util.List<StringgetSupportedProducts() {
         if ( == null) {
                = new com.amazonaws.internal.ListWithAutoConstructFlag<String>();
               .setAutoConstruct(true);
         }
         return ;
     }
    
    
A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.

Parameters:
supportedProducts A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
 
     public void setSupportedProducts(java.util.Collection<StringsupportedProducts) {
         if (supportedProducts == null) {
             this. = null;
             return;
         }
         com.amazonaws.internal.ListWithAutoConstructFlag<StringsupportedProductsCopy = new com.amazonaws.internal.ListWithAutoConstructFlag<String>(supportedProducts.size());
         supportedProductsCopy.addAll(supportedProducts);
         this. = supportedProductsCopy;
     }
    
    
A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.

NOTE: This method appends the values to the existing list (if any). Use setSupportedProducts(java.util.Collection) or withSupportedProducts(java.util.Collection) if you want to override the existing values.

Returns a reference to this object so that method calls can be chained together.

Parameters:
supportedProducts A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withSupportedProducts(String... supportedProducts) {
         if (getSupportedProducts() == nullsetSupportedProducts(new java.util.ArrayList<String>(supportedProducts.length));
         for (String value : supportedProducts) {
             getSupportedProducts().add(value);
         }
         return this;
     }
    
    
A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.

Returns a reference to this object so that method calls can be chained together.

Parameters:
supportedProducts A list of strings that indicates third-party software to use with the job flow. For more information, go to Use Third Party Applications with Amazon EMR. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withSupportedProducts(java.util.Collection<StringsupportedProducts) {
         if (supportedProducts == null) {
             this. = null;
         } else {
             com.amazonaws.internal.ListWithAutoConstructFlag<StringsupportedProductsCopy = new com.amazonaws.internal.ListWithAutoConstructFlag<String>(supportedProducts.size());
             supportedProductsCopy.addAll(supportedProducts);
             this. = supportedProductsCopy;
         }
 
         return this;
     }

    
A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.

Returns:
A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.
 
         if ( == null) {
               .setAutoConstruct(true);
         }
         return ;
     }
    
    
A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.

Parameters:
newSupportedProducts A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.
 
     public void setNewSupportedProducts(java.util.Collection<SupportedProductConfignewSupportedProducts) {
         if (newSupportedProducts == null) {
             this. = null;
             return;
         }
         newSupportedProductsCopy.addAll(newSupportedProducts);
         this. = newSupportedProductsCopy;
     }
    
    
A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.

NOTE: This method appends the values to the existing list (if any). Use setNewSupportedProducts(java.util.Collection) or withNewSupportedProducts(java.util.Collection) if you want to override the existing values.

Returns a reference to this object so that method calls can be chained together.

Parameters:
newSupportedProducts A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withNewSupportedProducts(SupportedProductConfig... newSupportedProducts) {
         if (getNewSupportedProducts() == nullsetNewSupportedProducts(new java.util.ArrayList<SupportedProductConfig>(newSupportedProducts.length));
         for (SupportedProductConfig value : newSupportedProducts) {
             getNewSupportedProducts().add(value);
         }
         return this;
     }
    
    
A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.

Returns a reference to this object so that method calls can be chained together.

Parameters:
newSupportedProducts A list of strings that indicates third-party software to use with the job flow that accepts a user argument list. EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action arguments. For more information, see Launch a Job Flow on the MapR Distribution for Hadoop. Currently supported values are:
  • "mapr-m3" - launch the job flow using MapR M3 Edition.
  • "mapr-m5" - launch the job flow using MapR M5 Edition.
  • "mapr" with the user arguments specifying "--edition,m3" or "--edition,m5" - launch the job flow using MapR M3 or M5 Edition respectively.
Returns:
A reference to this updated object so that method calls can be chained together.
 
         if (newSupportedProducts == null) {
             this. = null;
         } else {
             com.amazonaws.internal.ListWithAutoConstructFlag<SupportedProductConfignewSupportedProductsCopy = new com.amazonaws.internal.ListWithAutoConstructFlag<SupportedProductConfig>(newSupportedProducts.size());
             newSupportedProductsCopy.addAll(newSupportedProducts);
             this. = newSupportedProductsCopy;
         }
 
         return this;
     }

    
Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.

Returns:
Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.
 
     public Boolean isVisibleToAllUsers() {
         return ;
     }
    
    
Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.

Parameters:
visibleToAllUsers Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.
 
     public void setVisibleToAllUsers(Boolean visibleToAllUsers) {
         this. = visibleToAllUsers;
     }
    
    
Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.

Returns a reference to this object so that method calls can be chained together.

Parameters:
visibleToAllUsers Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.
Returns:
A reference to this updated object so that method calls can be chained together.
 
     public RunJobFlowRequest withVisibleToAllUsers(Boolean visibleToAllUsers) {
         this. = visibleToAllUsers;
         return this;
     }

    
Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.

Returns:
Whether the job flow is visible to all IAM users of the AWS account associated with the job flow. If this value is set to true, all IAM users of that AWS account can view and (if they have the proper policy permissions set) manage the job flow. If it is set to false, only the IAM user that created the job flow can view and manage it.
    public Boolean getVisibleToAllUsers() {
        return ;
    }

    
An IAM role for the job flow. The EC2 instances of the job flow assume this role. The default role is EMRJobflowDefault. In order to use the default role, you must have already created it using the CLI.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Returns:
An IAM role for the job flow. The EC2 instances of the job flow assume this role. The default role is EMRJobflowDefault. In order to use the default role, you must have already created it using the CLI.
    public String getJobFlowRole() {
        return ;
    }
    
    
An IAM role for the job flow. The EC2 instances of the job flow assume this role. The default role is EMRJobflowDefault. In order to use the default role, you must have already created it using the CLI.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
jobFlowRole An IAM role for the job flow. The EC2 instances of the job flow assume this role. The default role is EMRJobflowDefault. In order to use the default role, you must have already created it using the CLI.
    public void setJobFlowRole(String jobFlowRole) {
        this. = jobFlowRole;
    }
    
    
An IAM role for the job flow. The EC2 instances of the job flow assume this role. The default role is EMRJobflowDefault. In order to use the default role, you must have already created it using the CLI.

Returns a reference to this object so that method calls can be chained together.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
jobFlowRole An IAM role for the job flow. The EC2 instances of the job flow assume this role. The default role is EMRJobflowDefault. In order to use the default role, you must have already created it using the CLI.
Returns:
A reference to this updated object so that method calls can be chained together.
    public RunJobFlowRequest withJobFlowRole(String jobFlowRole) {
        this. = jobFlowRole;
        return this;
    }

    
The IAM role that will be assumed by the Amazon EMR service to access AWS resources on your behalf.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Returns:
The IAM role that will be assumed by the Amazon EMR service to access AWS resources on your behalf.
    public String getServiceRole() {
        return ;
    }
    
    
The IAM role that will be assumed by the Amazon EMR service to access AWS resources on your behalf.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
serviceRole The IAM role that will be assumed by the Amazon EMR service to access AWS resources on your behalf.
    public void setServiceRole(String serviceRole) {
        this. = serviceRole;
    }
    
    
The IAM role that will be assumed by the Amazon EMR service to access AWS resources on your behalf.

Returns a reference to this object so that method calls can be chained together.

Constraints:
Length: 0 - 10280
Pattern: [\u0020-\uD7FF\uE000-\uFFFD\uD800\uDC00-\uDBFF\uDFFF\r\n\t]*

Parameters:
serviceRole The IAM role that will be assumed by the Amazon EMR service to access AWS resources on your behalf.
Returns:
A reference to this updated object so that method calls can be chained together.
    public RunJobFlowRequest withServiceRole(String serviceRole) {
        this. = serviceRole;
        return this;
    }

    
A list of tags to associate with a cluster and propagate to Amazon EC2 instances.

Returns:
A list of tags to associate with a cluster and propagate to Amazon EC2 instances.
    public java.util.List<TaggetTags() {
        if ( == null) {
               = new com.amazonaws.internal.ListWithAutoConstructFlag<Tag>();
              .setAutoConstruct(true);
        }
        return ;
    }
    
    
A list of tags to associate with a cluster and propagate to Amazon EC2 instances.

Parameters:
tags A list of tags to associate with a cluster and propagate to Amazon EC2 instances.
    public void setTags(java.util.Collection<Tagtags) {
        if (tags == null) {
            this. = null;
            return;
        }
        tagsCopy.addAll(tags);
        this. = tagsCopy;
    }
    
    
A list of tags to associate with a cluster and propagate to Amazon EC2 instances.

NOTE: This method appends the values to the existing list (if any). Use setTags(java.util.Collection) or withTags(java.util.Collection) if you want to override the existing values.

Returns a reference to this object so that method calls can be chained together.

Parameters:
tags A list of tags to associate with a cluster and propagate to Amazon EC2 instances.
Returns:
A reference to this updated object so that method calls can be chained together.
    public RunJobFlowRequest withTags(Tag... tags) {
        if (getTags() == nullsetTags(new java.util.ArrayList<Tag>(tags.length));
        for (Tag value : tags) {
            getTags().add(value);
        }
        return this;
    }
    
    
A list of tags to associate with a cluster and propagate to Amazon EC2 instances.

Returns a reference to this object so that method calls can be chained together.

Parameters:
tags A list of tags to associate with a cluster and propagate to Amazon EC2 instances.
Returns:
A reference to this updated object so that method calls can be chained together.
        if (tags == null) {
            this. = null;
        } else {
            tagsCopy.addAll(tags);
            this. = tagsCopy;
        }
        return this;
    }

    
Returns a string representation of this object; useful for testing and debugging.

Returns:
A string representation of this object.
See also:
java.lang.Object.toString()
    @Override
    public String toString() {
        StringBuilder sb = new StringBuilder();
        sb.append("{");
        if (getName() != nullsb.append("Name: " + getName() + ",");
        if (getLogUri() != nullsb.append("LogUri: " + getLogUri() + ",");
        if (getAdditionalInfo() != nullsb.append("AdditionalInfo: " + getAdditionalInfo() + ",");
        if (getAmiVersion() != nullsb.append("AmiVersion: " + getAmiVersion() + ",");
        if (getInstances() != nullsb.append("Instances: " + getInstances() + ",");
        if (getSteps() != nullsb.append("Steps: " + getSteps() + ",");
        if (getBootstrapActions() != nullsb.append("BootstrapActions: " + getBootstrapActions() + ",");
        if (getSupportedProducts() != nullsb.append("SupportedProducts: " + getSupportedProducts() + ",");
        if (getNewSupportedProducts() != nullsb.append("NewSupportedProducts: " + getNewSupportedProducts() + ",");
        if (isVisibleToAllUsers() != nullsb.append("VisibleToAllUsers: " + isVisibleToAllUsers() + ",");
        if (getJobFlowRole() != nullsb.append("JobFlowRole: " + getJobFlowRole() + ",");
        if (getServiceRole() != nullsb.append("ServiceRole: " + getServiceRole() + ",");
        if (getTags() != nullsb.append("Tags: " + getTags() );
        sb.append("}");
        return sb.toString();
    }
    
    @Override
    public int hashCode() {
        final int prime = 31;
        int hashCode = 1;
        
        hashCode = prime * hashCode + ((getName() == null) ? 0 : getName().hashCode()); 
        hashCode = prime * hashCode + ((getLogUri() == null) ? 0 : getLogUri().hashCode()); 
        hashCode = prime * hashCode + ((getAdditionalInfo() == null) ? 0 : getAdditionalInfo().hashCode()); 
        hashCode = prime * hashCode + ((getAmiVersion() == null) ? 0 : getAmiVersion().hashCode()); 
        hashCode = prime * hashCode + ((getInstances() == null) ? 0 : getInstances().hashCode()); 
        hashCode = prime * hashCode + ((getSteps() == null) ? 0 : getSteps().hashCode()); 
        hashCode = prime * hashCode + ((getBootstrapActions() == null) ? 0 : getBootstrapActions().hashCode()); 
        hashCode = prime * hashCode + ((getSupportedProducts() == null) ? 0 : getSupportedProducts().hashCode()); 
        hashCode = prime * hashCode + ((getNewSupportedProducts() == null) ? 0 : getNewSupportedProducts().hashCode()); 
        hashCode = prime * hashCode + ((isVisibleToAllUsers() == null) ? 0 : isVisibleToAllUsers().hashCode()); 
        hashCode = prime * hashCode + ((getJobFlowRole() == null) ? 0 : getJobFlowRole().hashCode()); 
        hashCode = prime * hashCode + ((getServiceRole() == null) ? 0 : getServiceRole().hashCode()); 
        hashCode = prime * hashCode + ((getTags() == null) ? 0 : getTags().hashCode()); 
        return hashCode;
    }
    
    @Override
    public boolean equals(Object obj) {
        if (this == objreturn true;
        if (obj == nullreturn false;
        if (obj instanceof RunJobFlowRequest == falsereturn false;
        RunJobFlowRequest other = (RunJobFlowRequest)obj;
        
        if (other.getName() == null ^ this.getName() == nullreturn false;
        if (other.getName() != null && other.getName().equals(this.getName()) == falsereturn false
        if (other.getLogUri() == null ^ this.getLogUri() == nullreturn false;
        if (other.getLogUri() != null && other.getLogUri().equals(this.getLogUri()) == falsereturn false
        if (other.getAdditionalInfo() == null ^ this.getAdditionalInfo() == nullreturn false;
        if (other.getAdditionalInfo() != null && other.getAdditionalInfo().equals(this.getAdditionalInfo()) == falsereturn false
        if (other.getAmiVersion() == null ^ this.getAmiVersion() == nullreturn false;
        if (other.getAmiVersion() != null && other.getAmiVersion().equals(this.getAmiVersion()) == falsereturn false
        if (other.getInstances() == null ^ this.getInstances() == nullreturn false;
        if (other.getInstances() != null && other.getInstances().equals(this.getInstances()) == falsereturn false
        if (other.getSteps() == null ^ this.getSteps() == nullreturn false;
        if (other.getSteps() != null && other.getSteps().equals(this.getSteps()) == falsereturn false
        if (other.getBootstrapActions() == null ^ this.getBootstrapActions() == nullreturn false;
        if (other.getBootstrapActions() != null && other.getBootstrapActions().equals(this.getBootstrapActions()) == falsereturn false
        if (other.getSupportedProducts() == null ^ this.getSupportedProducts() == nullreturn false;
        if (other.getSupportedProducts() != null && other.getSupportedProducts().equals(this.getSupportedProducts()) == falsereturn false
        if (other.getNewSupportedProducts() == null ^ this.getNewSupportedProducts() == nullreturn false;
        if (other.getNewSupportedProducts() != null && other.getNewSupportedProducts().equals(this.getNewSupportedProducts()) == falsereturn false
        if (other.isVisibleToAllUsers() == null ^ this.isVisibleToAllUsers() == nullreturn false;
        if (other.isVisibleToAllUsers() != null && other.isVisibleToAllUsers().equals(this.isVisibleToAllUsers()) == falsereturn false
        if (other.getJobFlowRole() == null ^ this.getJobFlowRole() == nullreturn false;
        if (other.getJobFlowRole() != null && other.getJobFlowRole().equals(this.getJobFlowRole()) == falsereturn false
        if (other.getServiceRole() == null ^ this.getServiceRole() == nullreturn false;
        if (other.getServiceRole() != null && other.getServiceRole().equals(this.getServiceRole()) == falsereturn false
        if (other.getTags() == null ^ this.getTags() == nullreturn false;
        if (other.getTags() != null && other.getTags().equals(this.getTags()) == falsereturn false
        return true;
    }
    
    @Override
    public RunJobFlowRequest clone() {
        
            return (RunJobFlowRequestsuper.clone();
    }
}
    
New to GrepCode? Check out our FAQ X