Struct aws_sdk_emr::operation::set_unhealthy_node_replacement::builders::SetUnhealthyNodeReplacementFluentBuilder

pub struct SetUnhealthyNodeReplacementFluentBuilder { /* private fields */ }

Fluent builder constructing a request to SetUnhealthyNodeReplacement.

Specify whether to enable unhealthy node replacement, which lets Amazon EMR gracefully replace core nodes on a cluster if any nodes become unhealthy. For example, a node becomes unhealthy if disk usage is above 90%. If unhealthy node replacement is on and TerminationProtected are off, Amazon EMR immediately terminates the unhealthy core nodes. To use unhealthy node replacement and retain unhealthy core nodes, use to turn on termination protection. In such cases, Amazon EMR adds the unhealthy nodes to a denylist, reducing job interruptions and failures.

If unhealthy node replacement is on, Amazon EMR notifies YARN and other applications on the cluster to stop scheduling tasks with these nodes, moves the data, and then terminates the nodes.

For more information, see graceful node replacement in the Amazon EMR Management Guide.

Implementations

impl SetUnhealthyNodeReplacementFluentBuilder

pub fn as_input(&self) -> &SetUnhealthyNodeReplacementInputBuilder

Access the SetUnhealthyNodeReplacement as a reference.

pub async fn send( self, ) -> Result<SetUnhealthyNodeReplacementOutput, SdkError<SetUnhealthyNodeReplacementError, HttpResponse>>

Sends the request and returns the response.

If an error occurs, an SdkError will be returned with additional details that can be matched against.

By default, any retryable failures will be retried twice. Retry behavior is configurable with the RetryConfig, which can be set when configuring the client.

pub fn customize( self, ) -> CustomizableOperation<SetUnhealthyNodeReplacementOutput, SetUnhealthyNodeReplacementError, Self>

Consumes this builder, creating a customizable operation that can be modified before being sent.

pub fn job_flow_ids(self, input: impl Into<String>) -> Self

Appends an item to JobFlowIds.

To override the contents of this collection use set_job_flow_ids.

The list of strings that uniquely identify the clusters for which to turn on unhealthy node replacement. You can get these identifiers by running the RunJobFlow or the DescribeJobFlows operations.

pub fn set_job_flow_ids(self, input: Option<Vec<String>>) -> Self

The list of strings that uniquely identify the clusters for which to turn on unhealthy node replacement. You can get these identifiers by running the RunJobFlow or the DescribeJobFlows operations.

pub fn get_job_flow_ids(&self) -> &Option<Vec<String>>

The list of strings that uniquely identify the clusters for which to turn on unhealthy node replacement. You can get these identifiers by running the RunJobFlow or the DescribeJobFlows operations.

pub fn unhealthy_node_replacement(self, input: bool) -> Self

Indicates whether to turn on or turn off graceful unhealthy node replacement.

pub fn set_unhealthy_node_replacement(self, input: Option<bool>) -> Self

Indicates whether to turn on or turn off graceful unhealthy node replacement.

pub fn get_unhealthy_node_replacement(&self) -> &Option<bool>

Indicates whether to turn on or turn off graceful unhealthy node replacement.

Trait Implementations

impl Clone for SetUnhealthyNodeReplacementFluentBuilder

fn clone(&self) -> SetUnhealthyNodeReplacementFluentBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SetUnhealthyNodeReplacementFluentBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.