Повторное использование экземпляра Amazon Elastic MapReduce с помощью AWS Java SDK

Question

Эта ссылка (Re-use Amazon Elastic MapReduce instance) дает возможность повторно использовать экземпляр, как этот elastic-mapreduce --jobflow job-id \ --jar s3n://some-path/x.jar \ --step-name "New step name" \ --args ...

, но как я могу сделать то же самое в программе драйвера для запуска задания т.е. с помощью aws java sdk для запуска другого задания. Я думал, что в классе JobFlowInstancesConfig должен быть какой-то метод для установки id, но я ничего не мог найти. http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/elasticmapreduce/model/JobFlowInstancesConfig.html

Любая помощь приветствуется.

Answer 1

На самом деле я не собирался отвечать из-за downvotes, которые я получил изначально. я сделал что-то вроде этого (я не добавил весь код здесь, но ссылка следующее это может помочь)

static AddJobFlowStepsRequest AJFSrequest; 
List <StepConfig>steps = new LinkedList(); 
AJFSrequest = new AddJobFlowStepsRequest(); 
AJFSrequest.setJobFlowId("j-VKJMSIU34SFQ"); 

HadoopJarStepConfig jarConfig = new HadoopJarStepConfig(S3N_HADOOP_JAR); 
jarConfig.setArgs(ARGS_AS_LIST); 
StepConfig stepConfig =new StepConfig(S3N_HADOOP_JAR.substring(S3N_HADOOP_JAR.indexOf('/') + 1),jarConfig); 

String lastState = ""; 
steps.add(stepConfig); 
AJFSrequest.setSteps(steps); 
emr.addJobFlowSteps(AJFSrequest); 

http://chathurah.blogspot.in/2010/03/programmatically-launch-elastic-map.html