#[non_exhaustive]pub struct ParallelismConfigurationBuilder { /* private fields */ }
Expand description
A builder for ParallelismConfiguration
.
Implementations§
source§impl ParallelismConfigurationBuilder
impl ParallelismConfigurationBuilder
sourcepub fn configuration_type(self, input: ConfigurationType) -> Self
pub fn configuration_type(self, input: ConfigurationType) -> Self
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service. You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
sourcepub fn set_configuration_type(self, input: Option<ConfigurationType>) -> Self
pub fn set_configuration_type(self, input: Option<ConfigurationType>) -> Self
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service. You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
sourcepub fn get_configuration_type(&self) -> &Option<ConfigurationType>
pub fn get_configuration_type(&self) -> &Option<ConfigurationType>
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service. You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
sourcepub fn parallelism(self, input: i32) -> Self
pub fn parallelism(self, input: i32) -> Self
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled
is set to True, Managed Service for Apache Flink increases the CurrentParallelism
value in response to application load. The service can increase the CurrentParallelism
value up to the maximum parallelism, which is ParalellismPerKPU
times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism
value down to the Parallelism
setting.
sourcepub fn set_parallelism(self, input: Option<i32>) -> Self
pub fn set_parallelism(self, input: Option<i32>) -> Self
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled
is set to True, Managed Service for Apache Flink increases the CurrentParallelism
value in response to application load. The service can increase the CurrentParallelism
value up to the maximum parallelism, which is ParalellismPerKPU
times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism
value down to the Parallelism
setting.
sourcepub fn get_parallelism(&self) -> &Option<i32>
pub fn get_parallelism(&self) -> &Option<i32>
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled
is set to True, Managed Service for Apache Flink increases the CurrentParallelism
value in response to application load. The service can increase the CurrentParallelism
value up to the maximum parallelism, which is ParalellismPerKPU
times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism
value down to the Parallelism
setting.
sourcepub fn parallelism_per_kpu(self, input: i32) -> Self
pub fn parallelism_per_kpu(self, input: i32) -> Self
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application. For more information about KPUs, see Amazon Managed Service for Apache Flink Pricing.
sourcepub fn set_parallelism_per_kpu(self, input: Option<i32>) -> Self
pub fn set_parallelism_per_kpu(self, input: Option<i32>) -> Self
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application. For more information about KPUs, see Amazon Managed Service for Apache Flink Pricing.
sourcepub fn get_parallelism_per_kpu(&self) -> &Option<i32>
pub fn get_parallelism_per_kpu(&self) -> &Option<i32>
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application. For more information about KPUs, see Amazon Managed Service for Apache Flink Pricing.
sourcepub fn auto_scaling_enabled(self, input: bool) -> Self
pub fn auto_scaling_enabled(self, input: bool) -> Self
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
sourcepub fn set_auto_scaling_enabled(self, input: Option<bool>) -> Self
pub fn set_auto_scaling_enabled(self, input: Option<bool>) -> Self
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
sourcepub fn get_auto_scaling_enabled(&self) -> &Option<bool>
pub fn get_auto_scaling_enabled(&self) -> &Option<bool>
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
sourcepub fn build(self) -> Result<ParallelismConfiguration, BuildError>
pub fn build(self) -> Result<ParallelismConfiguration, BuildError>
Consumes the builder and constructs a ParallelismConfiguration
.
This method will fail if any of the following fields are not set:
Trait Implementations§
source§impl Clone for ParallelismConfigurationBuilder
impl Clone for ParallelismConfigurationBuilder
source§fn clone(&self) -> ParallelismConfigurationBuilder
fn clone(&self) -> ParallelismConfigurationBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Default for ParallelismConfigurationBuilder
impl Default for ParallelismConfigurationBuilder
source§fn default() -> ParallelismConfigurationBuilder
fn default() -> ParallelismConfigurationBuilder
source§impl PartialEq for ParallelismConfigurationBuilder
impl PartialEq for ParallelismConfigurationBuilder
source§fn eq(&self, other: &ParallelismConfigurationBuilder) -> bool
fn eq(&self, other: &ParallelismConfigurationBuilder) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for ParallelismConfigurationBuilder
Auto Trait Implementations§
impl Freeze for ParallelismConfigurationBuilder
impl RefUnwindSafe for ParallelismConfigurationBuilder
impl Send for ParallelismConfigurationBuilder
impl Sync for ParallelismConfigurationBuilder
impl Unpin for ParallelismConfigurationBuilder
impl UnwindSafe for ParallelismConfigurationBuilder
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more