#[non_exhaustive]
pub struct JobFlowInstancesConfigBuilder { /* private fields */ }
Expand description

A builder for JobFlowInstancesConfig.

Implementations§

source§

impl JobFlowInstancesConfigBuilder

source

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

The Amazon EC2 instance type of the master node.

source

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

The Amazon EC2 instance type of the master node.

source

pub fn get_master_instance_type(&self) -> &Option<String>

The Amazon EC2 instance type of the master node.

source

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

The Amazon EC2 instance type of the core and task nodes.

source

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

The Amazon EC2 instance type of the core and task nodes.

source

pub fn get_slave_instance_type(&self) -> &Option<String>

The Amazon EC2 instance type of the core and task nodes.

source

pub fn instance_count(self, input: i32) -> Self

The number of Amazon EC2 instances in the cluster.

source

pub fn set_instance_count(self, input: Option<i32>) -> Self

The number of Amazon EC2 instances in the cluster.

source

pub fn get_instance_count(&self) -> &Option<i32>

The number of Amazon EC2 instances in the cluster.

source

pub fn instance_groups(self, input: InstanceGroupConfig) -> Self

Appends an item to instance_groups.

To override the contents of this collection use set_instance_groups.

Configuration for the instance groups in a cluster.

source

pub fn set_instance_groups( self, input: Option<Vec<InstanceGroupConfig>> ) -> Self

Configuration for the instance groups in a cluster.

source

pub fn get_instance_groups(&self) -> &Option<Vec<InstanceGroupConfig>>

Configuration for the instance groups in a cluster.

source

pub fn instance_fleets(self, input: InstanceFleetConfig) -> Self

Appends an item to instance_fleets.

To override the contents of this collection use set_instance_fleets.

The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.

Describes the Amazon EC2 instances and instance configurations for clusters that use the instance fleet configuration.

source

pub fn set_instance_fleets( self, input: Option<Vec<InstanceFleetConfig>> ) -> Self

The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.

Describes the Amazon EC2 instances and instance configurations for clusters that use the instance fleet configuration.

source

pub fn get_instance_fleets(&self) -> &Option<Vec<InstanceFleetConfig>>

The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.

Describes the Amazon EC2 instances and instance configurations for clusters that use the instance fleet configuration.

source

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

The name of the Amazon EC2 key pair that can be used to connect to the master node using SSH as the user called "hadoop."

source

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

The name of the Amazon EC2 key pair that can be used to connect to the master node using SSH as the user called "hadoop."

source

pub fn get_ec2_key_name(&self) -> &Option<String>

The name of the Amazon EC2 key pair that can be used to connect to the master node using SSH as the user called "hadoop."

source

pub fn placement(self, input: PlacementType) -> Self

The Availability Zone in which the cluster runs.

source

pub fn set_placement(self, input: Option<PlacementType>) -> Self

The Availability Zone in which the cluster runs.

source

pub fn get_placement(&self) -> &Option<PlacementType>

The Availability Zone in which the cluster runs.

source

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

Specifies whether the cluster should remain available after completing all steps. Defaults to true. For more information about configuring cluster termination, see Control Cluster Termination in the EMR Management Guide.

source

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

Specifies whether the cluster should remain available after completing all steps. Defaults to true. For more information about configuring cluster termination, see Control Cluster Termination in the EMR Management Guide.

source

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

Specifies whether the cluster should remain available after completing all steps. Defaults to true. For more information about configuring cluster termination, see Control Cluster Termination in the EMR Management Guide.

source

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

Specifies whether to lock the cluster to prevent the Amazon EC2 instances from being terminated by API call, user intervention, or in the event of a job-flow error.

source

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

Specifies whether to lock the cluster to prevent the Amazon EC2 instances from being terminated by API call, user intervention, or in the event of a job-flow error.

source

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

Specifies whether to lock the cluster to prevent the Amazon EC2 instances from being terminated by API call, user intervention, or in the event of a job-flow error.

source

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

Applies only to Amazon EMR release versions earlier than 4.0. The Hadoop version for the cluster. Valid inputs are "0.18" (no longer maintained), "0.20" (no longer maintained), "0.20.205" (no longer maintained), "1.0.3", "2.2.0", or "2.4.0". If you do not set this value, the default of 0.18 is used, unless the AmiVersion parameter is set in the RunJobFlow call, in which case the default version of Hadoop for that AMI version is used.

source

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

Applies only to Amazon EMR release versions earlier than 4.0. The Hadoop version for the cluster. Valid inputs are "0.18" (no longer maintained), "0.20" (no longer maintained), "0.20.205" (no longer maintained), "1.0.3", "2.2.0", or "2.4.0". If you do not set this value, the default of 0.18 is used, unless the AmiVersion parameter is set in the RunJobFlow call, in which case the default version of Hadoop for that AMI version is used.

source

pub fn get_hadoop_version(&self) -> &Option<String>

Applies only to Amazon EMR release versions earlier than 4.0. The Hadoop version for the cluster. Valid inputs are "0.18" (no longer maintained), "0.20" (no longer maintained), "0.20.205" (no longer maintained), "1.0.3", "2.2.0", or "2.4.0". If you do not set this value, the default of 0.18 is used, unless the AmiVersion parameter is set in the RunJobFlow call, in which case the default version of Hadoop for that AMI version is used.

source

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

Applies to clusters that use the uniform instance group configuration. To launch the cluster in Amazon Virtual Private Cloud (Amazon VPC), set this parameter to the identifier of the Amazon VPC subnet where you want the cluster to launch. If you do not specify this value and your account supports EC2-Classic, the cluster launches in EC2-Classic.

source

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

Applies to clusters that use the uniform instance group configuration. To launch the cluster in Amazon Virtual Private Cloud (Amazon VPC), set this parameter to the identifier of the Amazon VPC subnet where you want the cluster to launch. If you do not specify this value and your account supports EC2-Classic, the cluster launches in EC2-Classic.

source

pub fn get_ec2_subnet_id(&self) -> &Option<String>

Applies to clusters that use the uniform instance group configuration. To launch the cluster in Amazon Virtual Private Cloud (Amazon VPC), set this parameter to the identifier of the Amazon VPC subnet where you want the cluster to launch. If you do not specify this value and your account supports EC2-Classic, the cluster launches in EC2-Classic.

source

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

Appends an item to ec2_subnet_ids.

To override the contents of this collection use set_ec2_subnet_ids.

Applies to clusters that use the instance fleet configuration. When multiple Amazon EC2 subnet IDs are specified, Amazon EMR evaluates them and launches instances in the optimal subnet.

The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.

source

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

Applies to clusters that use the instance fleet configuration. When multiple Amazon EC2 subnet IDs are specified, Amazon EMR evaluates them and launches instances in the optimal subnet.

The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.

source

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

Applies to clusters that use the instance fleet configuration. When multiple Amazon EC2 subnet IDs are specified, Amazon EMR evaluates them and launches instances in the optimal subnet.

The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.

source

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

The identifier of the Amazon EC2 security group for the master node. If you specify EmrManagedMasterSecurityGroup, you must also specify EmrManagedSlaveSecurityGroup.

source

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

The identifier of the Amazon EC2 security group for the master node. If you specify EmrManagedMasterSecurityGroup, you must also specify EmrManagedSlaveSecurityGroup.

source

pub fn get_emr_managed_master_security_group(&self) -> &Option<String>

The identifier of the Amazon EC2 security group for the master node. If you specify EmrManagedMasterSecurityGroup, you must also specify EmrManagedSlaveSecurityGroup.

source

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

The identifier of the Amazon EC2 security group for the core and task nodes. If you specify EmrManagedSlaveSecurityGroup, you must also specify EmrManagedMasterSecurityGroup.

source

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

The identifier of the Amazon EC2 security group for the core and task nodes. If you specify EmrManagedSlaveSecurityGroup, you must also specify EmrManagedMasterSecurityGroup.

source

pub fn get_emr_managed_slave_security_group(&self) -> &Option<String>

The identifier of the Amazon EC2 security group for the core and task nodes. If you specify EmrManagedSlaveSecurityGroup, you must also specify EmrManagedMasterSecurityGroup.

source

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

The identifier of the Amazon EC2 security group for the Amazon EMR service to access clusters in VPC private subnets.

source

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

The identifier of the Amazon EC2 security group for the Amazon EMR service to access clusters in VPC private subnets.

source

pub fn get_service_access_security_group(&self) -> &Option<String>

The identifier of the Amazon EC2 security group for the Amazon EMR service to access clusters in VPC private subnets.

source

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

Appends an item to additional_master_security_groups.

To override the contents of this collection use set_additional_master_security_groups.

A list of additional Amazon EC2 security group IDs for the master node.

source

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

A list of additional Amazon EC2 security group IDs for the master node.

source

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

A list of additional Amazon EC2 security group IDs for the master node.

source

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

Appends an item to additional_slave_security_groups.

To override the contents of this collection use set_additional_slave_security_groups.

A list of additional Amazon EC2 security group IDs for the core and task nodes.

source

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

A list of additional Amazon EC2 security group IDs for the core and task nodes.

source

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

A list of additional Amazon EC2 security group IDs for the core and task nodes.

source

pub fn build(self) -> JobFlowInstancesConfig

Consumes the builder and constructs a JobFlowInstancesConfig.

Trait Implementations§

source§

impl Clone for JobFlowInstancesConfigBuilder

source§

fn clone(&self) -> JobFlowInstancesConfigBuilder

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for JobFlowInstancesConfigBuilder

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for JobFlowInstancesConfigBuilder

source§

fn default() -> JobFlowInstancesConfigBuilder

Returns the “default value” for a type. Read more
source§

impl PartialEq for JobFlowInstancesConfigBuilder

source§

fn eq(&self, other: &JobFlowInstancesConfigBuilder) -> bool

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl StructuralPartialEq for JobFlowInstancesConfigBuilder

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more