org.finra.herd.dao

Interface EmrDao

All Known Implementing Classes:

EmrDaoImpl

public interface EmrDao

A DAO for Amazon AWS EMR.

Method Summary

Modifier and Type	Method and Description
List<String>	addEmrMasterSecurityGroups(String clusterId, List<String> securityGroups, AwsParamsDto awsParams)
String	addEmrStep(String clusterId, com.amazonaws.services.elasticmapreduce.model.StepConfig emrStepConfig, AwsParamsDto awsParamsDto)
String	createEmrCluster(String clusterName, EmrClusterDefinition emrClusterDefinition, AwsParamsDto awsParams)
com.amazonaws.services.elasticmapreduce.model.ClusterSummary	getActiveEmrClusterByName(String clusterName, AwsParamsDto awsParams)
com.amazonaws.services.elasticmapreduce.model.StepSummary	getClusterActiveStep(String clusterId, AwsParamsDto awsParamsDto)
com.amazonaws.services.elasticmapreduce.model.Step	getClusterStep(String clusterId, String stepId, AwsParamsDto awsParamsDto)
com.amazonaws.services.elasticmapreduce.AmazonElasticMapReduceClient	getEmrClient(AwsParamsDto awsParamsDto)
com.amazonaws.services.elasticmapreduce.model.Cluster	getEmrClusterById(String clusterId, AwsParamsDto awsParams)
String	getEmrClusterStatusById(String clusterId, AwsParamsDto awsParams)
com.amazonaws.services.elasticmapreduce.model.Instance	getEmrMasterInstance(String clusterId, AwsParamsDto awsParams)
void	terminateEmrCluster(String clusterId, boolean overrideTerminationProtection, AwsParamsDto awsParams)

Method Detail

addEmrStep

String addEmrStep(String clusterId,
                  com.amazonaws.services.elasticmapreduce.model.StepConfig emrStepConfig,
                  AwsParamsDto awsParamsDto)
           throws Exception

Throws:

Exception

addEmrMasterSecurityGroups

List<String> addEmrMasterSecurityGroups(String clusterId,
                                        List<String> securityGroups,
                                        AwsParamsDto awsParams)
                                 throws Exception

Throws:

Exception

getEmrMasterInstance

com.amazonaws.services.elasticmapreduce.model.Instance getEmrMasterInstance(String clusterId,
                                                                            AwsParamsDto awsParams)
                                                                     throws Exception

Throws:

Exception

createEmrCluster

String createEmrCluster(String clusterName,
                        EmrClusterDefinition emrClusterDefinition,
                        AwsParamsDto awsParams)

terminateEmrCluster

void terminateEmrCluster(String clusterId,
                         boolean overrideTerminationProtection,
                         AwsParamsDto awsParams)

getEmrClusterById

com.amazonaws.services.elasticmapreduce.model.Cluster getEmrClusterById(String clusterId,
                                                                        AwsParamsDto awsParams)

getEmrClusterStatusById

String getEmrClusterStatusById(String clusterId,
                               AwsParamsDto awsParams)

getActiveEmrClusterByName

com.amazonaws.services.elasticmapreduce.model.ClusterSummary getActiveEmrClusterByName(String clusterName,
                                                                                       AwsParamsDto awsParams)

getClusterActiveStep

com.amazonaws.services.elasticmapreduce.model.StepSummary getClusterActiveStep(String clusterId,
                                                                               AwsParamsDto awsParamsDto)

getClusterStep

com.amazonaws.services.elasticmapreduce.model.Step getClusterStep(String clusterId,
                                                                  String stepId,
                                                                  AwsParamsDto awsParamsDto)

getEmrClient

com.amazonaws.services.elasticmapreduce.AmazonElasticMapReduceClient getEmrClient(AwsParamsDto awsParamsDto)