| Package | Description |
|---|---|
| org.finra.herd.dao | |
| org.finra.herd.dao.helper | |
| org.finra.herd.dao.impl | |
| org.finra.herd.model.dto |
| Modifier and Type | Method and Description |
|---|---|
List<String> |
EmrDao.addEmrMasterSecurityGroups(String clusterId,
List<String> securityGroups,
AwsParamsDto awsParams) |
String |
EmrDao.addEmrStep(String clusterId,
com.amazonaws.services.elasticmapreduce.model.StepConfig emrStepConfig,
AwsParamsDto awsParamsDto) |
List<String> |
Ec2Dao.addSecurityGroupsToEc2Instance(String ec2InstanceId,
List<String> securityGroups,
AwsParamsDto awsParams) |
String |
EmrDao.createEmrCluster(String clusterName,
EmrClusterDefinition emrClusterDefinition,
AwsParamsDto awsParams) |
String |
KmsDao.decrypt(AwsParamsDto awsParamsDto,
String base64ciphertextBlob) |
com.amazonaws.services.elasticmapreduce.model.ClusterSummary |
EmrDao.getActiveEmrClusterByName(String clusterName,
AwsParamsDto awsParams) |
List<com.amazonaws.services.ec2.model.AvailabilityZone> |
Ec2Dao.getAvailabilityZonesForSubnetIds(Collection<com.amazonaws.services.ec2.model.Subnet> subnets,
AwsParamsDto awsParamsDto)
Returns a list of availability zones that contains the given collections of subnets.
|
com.amazonaws.services.elasticmapreduce.model.StepSummary |
EmrDao.getClusterActiveStep(String clusterId,
AwsParamsDto awsParamsDto) |
com.amazonaws.services.elasticmapreduce.model.Step |
EmrDao.getClusterStep(String clusterId,
String stepId,
AwsParamsDto awsParamsDto) |
com.amazonaws.services.ec2.AmazonEC2Client |
AwsClientFactory.getEc2Client(AwsParamsDto awsParamsDto)
Create the EC2 client with the given proxy and access key details This is the main AmazonEC2Client object
|
com.amazonaws.services.ec2.AmazonEC2Client |
Ec2Dao.getEc2Client(AwsParamsDto awsParamsDto) |
com.amazonaws.services.elasticmapreduce.AmazonElasticMapReduceClient |
AwsClientFactory.getEmrClient(AwsParamsDto awsParamsDto)
Create the EMR client with the given proxy and access key details.
|
com.amazonaws.services.elasticmapreduce.AmazonElasticMapReduceClient |
EmrDao.getEmrClient(AwsParamsDto awsParamsDto) |
com.amazonaws.services.elasticmapreduce.model.Cluster |
EmrDao.getEmrClusterById(String clusterId,
AwsParamsDto awsParams) |
String |
EmrDao.getEmrClusterStatusById(String clusterId,
AwsParamsDto awsParams) |
com.amazonaws.services.elasticmapreduce.model.Instance |
EmrDao.getEmrMasterInstance(String clusterId,
AwsParamsDto awsParams) |
List<com.amazonaws.services.ec2.model.SpotPrice> |
Ec2Dao.getLatestSpotPrices(String availabilityZone,
Collection<String> instanceTypes,
Collection<String> productDescriptions,
AwsParamsDto awsParamsDto)
Returns the latest spot prices for each of the instance types specified in the given AZ.
|
List<com.amazonaws.services.ec2.model.Subnet> |
Ec2Dao.getSubnets(Collection<String> subnetIds,
AwsParamsDto awsParamsDto)
Returns a list of subnets by their subnet IDs.
|
com.amazonaws.services.securitytoken.model.Credentials |
StsDao.getTemporarySecurityCredentials(AwsParamsDto awsParamsDto,
String sessionName,
String awsRoleArn,
int awsRoleDurationSeconds,
com.amazonaws.auth.policy.Policy policy) |
void |
SqsDao.sendSqsTextMessage(AwsParamsDto awsParamsDto,
String queueName,
String messageText) |
void |
EmrDao.terminateEmrCluster(String clusterId,
boolean overrideTerminationProtection,
AwsParamsDto awsParams) |
| Modifier and Type | Method and Description |
|---|---|
AwsParamsDto |
AwsHelper.getAwsParamsDto()
Constructs awsParamsDto with AWS parameters.
|
AwsParamsDto |
EmrHelper.getAwsparamsDtoByAcccountId(String accountId)
Get the AWS Params DTO for the account Id
if no account id is specified, use the default
|
| Modifier and Type | Method and Description |
|---|---|
com.amazonaws.ClientConfiguration |
AwsHelper.getClientConfiguration(AwsParamsDto awsParamsDto)
Returns client configuration options that might contain proxy settings set per specified AWS parameters DTO.
|
void |
EmrPricingHelper.updateEmrClusterDefinitionWithBestPrice(EmrClusterAlternateKeyDto emrClusterAlternateKeyDto,
EmrClusterDefinition emrClusterDefinition,
AwsParamsDto awsParamsDto)
Finds the best price for each master and core instances based on the subnets and master and core instance search parameters given in the definition.
|
| Modifier and Type | Method and Description |
|---|---|
List<String> |
EmrDaoImpl.addEmrMasterSecurityGroups(String clusterId,
List<String> securityGroups,
AwsParamsDto awsParams)
Add Security groups to the master node of EMR cluster.
|
String |
EmrDaoImpl.addEmrStep(String clusterId,
com.amazonaws.services.elasticmapreduce.model.StepConfig emrStepConfig,
AwsParamsDto awsParamsDto)
Add an EMR Step.
|
List<String> |
Ec2DaoImpl.addSecurityGroupsToEc2Instance(String ec2InstanceId,
List<String> securityGroups,
AwsParamsDto awsParams)
Adds the security groups to an EC2 instance.
|
String |
EmrDaoImpl.createEmrCluster(String clusterName,
EmrClusterDefinition emrClusterDefinition,
AwsParamsDto awsParams)
Create the EMR cluster.
|
String |
KmsDaoImpl.decrypt(AwsParamsDto awsParamsDto,
String base64ciphertextBlob) |
com.amazonaws.services.elasticmapreduce.model.ClusterSummary |
EmrDaoImpl.getActiveEmrClusterByName(String clusterName,
AwsParamsDto awsParams)
Get an Active EMR cluster by the cluster name.
|
List<com.amazonaws.services.ec2.model.AvailabilityZone> |
Ec2DaoImpl.getAvailabilityZonesForSubnetIds(Collection<com.amazonaws.services.ec2.model.Subnet> subnets,
AwsParamsDto awsParamsDto)
This implementation uses the DescribeAvailabilityZones API to get the list of AZs.
|
com.amazonaws.services.elasticmapreduce.model.StepSummary |
EmrDaoImpl.getClusterActiveStep(String clusterId,
AwsParamsDto awsParamsDto)
Gets the active step on the cluster if any.
|
com.amazonaws.services.elasticmapreduce.model.Step |
EmrDaoImpl.getClusterStep(String clusterId,
String stepId,
AwsParamsDto awsParamsDto)
Gets the step on the cluster.
|
com.amazonaws.services.ec2.AmazonEC2Client |
Ec2DaoImpl.getEc2Client(AwsParamsDto awsParamsDto)
Create the EC2 client with the given proxy and access key details This is the main AmazonEC2Client object
|
com.amazonaws.services.elasticmapreduce.AmazonElasticMapReduceClient |
EmrDaoImpl.getEmrClient(AwsParamsDto awsParamsDto)
Create the EMR client with the given proxy and access key details.
|
com.amazonaws.services.elasticmapreduce.model.Cluster |
EmrDaoImpl.getEmrClusterById(String clusterId,
AwsParamsDto awsParams)
Get EMR cluster by cluster Id.
|
String |
EmrDaoImpl.getEmrClusterStatusById(String clusterId,
AwsParamsDto awsParams)
Get EMR cluster status by cluster Id.
|
com.amazonaws.services.elasticmapreduce.model.Instance |
EmrDaoImpl.getEmrMasterInstance(String clusterId,
AwsParamsDto awsParams)
Gets the master instance of the EMR cluster.
|
List<com.amazonaws.services.ec2.model.SpotPrice> |
Ec2DaoImpl.getLatestSpotPrices(String availabilityZone,
Collection<String> instanceTypes,
Collection<String> productDescriptions,
AwsParamsDto awsParamsDto)
This implementation uses DescribeSpotPriceHistory API which returns the latest spot price history for the specified AZ and instance types.
|
List<com.amazonaws.services.ec2.model.Subnet> |
Ec2DaoImpl.getSubnets(Collection<String> subnetIds,
AwsParamsDto awsParamsDto)
This implementation uses the DescribeSubnets API.
|
com.amazonaws.services.securitytoken.model.Credentials |
StsDaoImpl.getTemporarySecurityCredentials(AwsParamsDto awsParamsDto,
String sessionName,
String awsRoleArn,
int awsRoleDurationSeconds,
com.amazonaws.auth.policy.Policy policy)
Returns a set of temporary security credentials (consisting of an access key ID, a secret access key, and a security token) that can be used to access
the specified AWS resource.
|
void |
SqsDaoImpl.sendSqsTextMessage(AwsParamsDto awsParamsDto,
String queueName,
String messageText)
Sends a text message to the specified AWS SQS queue.
|
void |
EmrDaoImpl.terminateEmrCluster(String clusterId,
boolean overrideTerminationProtection,
AwsParamsDto awsParams)
Terminates the EMR cluster.
|
| Modifier and Type | Class and Description |
|---|---|
class |
S3FileCopyRequestParamsDto
A DTO that holds various parameters for making an S3 file copy request.
|
class |
S3FileTransferRequestParamsDto
A DTO that holds various parameters for making an S3 file/directory transfer request.
|
| Modifier and Type | Method and Description |
|---|---|
AwsParamsDto |
CompleteUploadSingleParamsDto.getAwsParams() |
| Modifier and Type | Method and Description |
|---|---|
void |
CompleteUploadSingleParamsDto.setAwsParams(AwsParamsDto awsParams) |
| Constructor and Description |
|---|
CompleteUploadSingleParamsDto(BusinessObjectDataKey sourceBusinessObjectDataKey,
String sourceBucketName,
String sourceFilePath,
String sourceOldStatus,
String sourceNewStatus,
BusinessObjectDataKey targetBusinessObjectDataKey,
String targetBucketName,
String targetFilePath,
String targetOldStatus,
String targetNewStatus,
String kmsKeyId,
AwsParamsDto awsParams)
Fully-initialising value constructor.
|
Copyright © 2017. All rights reserved.