putAutoScalingPolicy method

Future<PutAutoScalingPolicyOutput> putAutoScalingPolicy({ required AutoScalingPolicy autoScalingPolicy, required String clusterId, required String instanceGroupId, })

Creates or updates an automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster. The automatic scaling policy defines how an instance group dynamically adds and terminates EC2 instances in response to the value of a CloudWatch metric.

Parameter autoScalingPolicy : Specifies the definition of the automatic scaling policy.

Parameter clusterId : Specifies the ID of a cluster. The instance group to which the automatic scaling policy is applied is within this cluster.

Parameter instanceGroupId : Specifies the ID of the instance group to which the automatic scaling policy is applied.

Implementation

Future<PutAutoScalingPolicyOutput> putAutoScalingPolicy({
  required AutoScalingPolicy autoScalingPolicy,
  required String clusterId,
  required String instanceGroupId,
}) async {
  ArgumentError.checkNotNull(autoScalingPolicy, 'autoScalingPolicy');
  ArgumentError.checkNotNull(clusterId, 'clusterId');
  ArgumentError.checkNotNull(instanceGroupId, 'instanceGroupId');
  final headers = <String, String>{
    'Content-Type': 'application/x-amz-json-1.1',
    'X-Amz-Target': 'ElasticMapReduce.PutAutoScalingPolicy'
  };
  final jsonResponse = await _protocol.send(
    method: 'POST',
    requestUri: '/',
    exceptionFnMap: _exceptionFns,
    // TODO queryParams
    headers: headers,
    payload: {
      'AutoScalingPolicy': autoScalingPolicy,
      'ClusterId': clusterId,
      'InstanceGroupId': instanceGroupId,
    },
  );

  return PutAutoScalingPolicyOutput.fromJson(jsonResponse.body);
}