@Override public String addEmrStep(String clusterId,StepConfig emrStepConfig,AwsParamsDto awsParamsDto) throws Exception {
  List<StepConfig> steps=new ArrayList<>();
  steps.add(emrStepConfig);
  AddJobFlowStepsRequest jobFlowStepRequest=new AddJobFlowStepsRequest(clusterId,steps);
  List<String> emrStepIds=emrOperations.addJobFlowStepsRequest(getEmrClient(awsParamsDto),jobFlowStepRequest);
  return emrStepIds.get(0);
}

@ Override public String addEmrStep ( String clusterId , StepConfig emrStepConfig , AwsParamsDto awsParamsDto ) throws Exception { List < StepConfig > steps = new ArrayList < > ( ) ; steps . add ( emrStepConfig ) ; AddJobFlowStepsRequest jobFlowStepRequest = new AddJobFlowStepsRequest ( clusterId , steps ) ; List < String > emrStepIds = emrOperations . addJobFlowStepsRequest ( getEmrClient ( awsParamsDto ) , jobFlowStepRequest ) ; return emrStepIds . get ( 0 ) ; }
add an emr step . this method adds the step to emr cluster based on the input .
