Class BootstrapActions
- java.lang.Object
-
- com.amazonaws.services.elasticmapreduce.util.BootstrapActions
-
public class BootstrapActions extends Object
Class that provides helper methods for constructing predefined bootstrap actions.AWSCredentials credentials = new BasicAWSCredentials(accessKey, secretKey); AmazonElasticMapReduce emr = new AmazonElasticMapReduceClient(credentials); BootstrapActions bootstrapActions = new BootstrapActions(); RunJobFlowRequest request = new RunJobFlowRequest() .withName("Job Flow With Bootstrap Actions") .withBootstrapActions( bootstrapActions.newRunIf( "instance.isMaster=true", bootstrapActions.newConfigureDaemons() .withHeapSize(Daemon.JobTracker, 2048) .build())) .withLogUri("s3://log-bucket/") .withInstances(new JobFlowInstancesConfig() .withEc2KeyName("keypair") .withHadoopVersion("0.20") .withInstanceCount(5) .withKeepJobFlowAliveWhenNoSteps(true) .withMasterInstanceType("m1.small") .withSlaveInstanceType("m1.small")); RunJobFlowResult result = emr.runJobFlow(request);
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
BootstrapActions.ConfigFile
Enum specifying all valid config files.class
BootstrapActions.ConfigureDaemons
class
BootstrapActions.ConfigureHadoop
Deprecated.static class
BootstrapActions.Daemon
List of Hadoop daemons which can be configured.
-
Constructor Summary
Constructors Constructor Description BootstrapActions()
Creates a new default BootstrapActions for us in us-east-1.BootstrapActions(String bucket)
Creates a new BootstrapActions.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BootstrapActions.ConfigureDaemons
newConfigureDaemons()
Create a new bootstrap action which lets you configure Hadoop's daemons.BootstrapActions.ConfigureHadoop
newConfigureHadoop()
Create a new bootstrap action which lets you configure Hadoop's XML files.BootstrapActionConfig
newRunIf(String condition, BootstrapActionConfig config)
Create a new run-if bootstrap action which lets you conditionally run bootstrap actions.
-
-
-
Constructor Detail
-
BootstrapActions
public BootstrapActions()
Creates a new default BootstrapActions for us in us-east-1.
-
BootstrapActions
public BootstrapActions(String bucket)
Creates a new BootstrapActions.- Parameters:
bucket
- the bucket from which to download the bootstrap actions.
-
-
Method Detail
-
newRunIf
public BootstrapActionConfig newRunIf(String condition, BootstrapActionConfig config)
Create a new run-if bootstrap action which lets you conditionally run bootstrap actions.- Parameters:
condition
- The condition to evaluate, if true the bootstrap action executes.config
- The bootstrap action to execute in case of successful evaluation.- Returns:
- A BootstrapActionConfig to be provided when running a job flow.
-
newConfigureHadoop
public BootstrapActions.ConfigureHadoop newConfigureHadoop()
Create a new bootstrap action which lets you configure Hadoop's XML files. ConfigureHadoop is deprecated. Use.elasticmapreduce.model.RunJobFlowRequest#setConfigurations
instead. For more information see,
-
newConfigureDaemons
public BootstrapActions.ConfigureDaemons newConfigureDaemons()
Create a new bootstrap action which lets you configure Hadoop's daemons. The options are written to the hadoop-user-env.sh file.
-
-