org.finra.herd.dao.helper

Class EmrPricingHelper

java.lang.Object

org.finra.herd.dao.helper.AwsHelper

org.finra.herd.dao.helper.EmrPricingHelper

@Component
public class EmrPricingHelper
extends AwsHelper

Encapsulates logic for calculating the best price for EMR cluster.

Field Summary

Fields inherited from class org.finra.herd.dao.helper.AwsHelper

configurationHelper

Constructor Summary

Constructors

Constructor and Description
EmrPricingHelper()

Method Summary

Modifier and Type	Method and Description
BigDecimal	getTotalCost(Ec2PriceDto ec2Price) Returns the total cost per hour to run the requested number of instances for the given price.
void	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.

Methods inherited from class org.finra.herd.dao.helper.AwsHelper

getAwsParamsDto, getClientConfiguration, getTransferRateInKilobytesPerSecond, getTransferRateInMegabitsPerSecond

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EmrPricingHelper

public EmrPricingHelper()

Method Detail

updateEmrClusterDefinitionWithBestPrice

public void 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.

The results of the findings are used to update the given definition.

If the instance's instanceSpotPrice is set, the instance definition will keep that value. If the instance's instanceMaxSearchPrice is set, the best price will be found. If the found price is spot, the instanceSpotPrice will be set to the value of instanceMaxSearchPrice. If the found price is on-demand, the instanceSpotPrice will be removed. The definition's subnetId will be set to the particular subnet which the best price is found. The value will always be replaced by a single subnet ID.

The definition's instanceMaxSearchPrice and instanceOnDemandThreshold will be removed by this operation.

Parameters:

emrClusterAlternateKeyDto - EMR cluster alternate key

emrClusterDefinition - The EMR cluster definition with search criteria, and the definition that will be updated

awsParamsDto - the AWS related parameters for access/secret keys and proxy details

getTotalCost

public BigDecimal getTotalCost(Ec2PriceDto ec2Price)

Returns the total cost per hour to run the requested number of instances for the given price. Returns the instance price multiplied by the number of instances.

Parameters:

ec2Price - the EC2 pricing information

Returns:

the USD per hour