Struct aws_sdk_kinesisanalyticsv2::types::builders::ParallelismConfigurationDescriptionBuilder
source · #[non_exhaustive]pub struct ParallelismConfigurationDescriptionBuilder { /* private fields */ }
Expand description
A builder for ParallelismConfigurationDescription
.
Implementations§
source§impl ParallelismConfigurationDescriptionBuilder
impl ParallelismConfigurationDescriptionBuilder
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.
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.
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.
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, then Managed Service for Apache Flink can increase the CurrentParallelism
value in response to application load. The service can increase CurrentParallelism
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, then Managed Service for Apache Flink can increase the CurrentParallelism
value in response to application load. The service can increase CurrentParallelism
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, then Managed Service for Apache Flink can increase the CurrentParallelism
value in response to application load. The service can increase CurrentParallelism
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.
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.
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.
sourcepub fn current_parallelism(self, input: i32) -> Self
pub fn current_parallelism(self, input: i32) -> Self
Describes the current 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 can increase this value in response to application load. The service can increase this 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_current_parallelism(self, input: Option<i32>) -> Self
pub fn set_current_parallelism(self, input: Option<i32>) -> Self
Describes the current 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 can increase this value in response to application load. The service can increase this 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_current_parallelism(&self) -> &Option<i32>
pub fn get_current_parallelism(&self) -> &Option<i32>
Describes the current 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 can increase this value in response to application load. The service can increase this 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 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) -> ParallelismConfigurationDescription
pub fn build(self) -> ParallelismConfigurationDescription
Consumes the builder and constructs a ParallelismConfigurationDescription
.
Trait Implementations§
source§impl Clone for ParallelismConfigurationDescriptionBuilder
impl Clone for ParallelismConfigurationDescriptionBuilder
source§fn clone(&self) -> ParallelismConfigurationDescriptionBuilder
fn clone(&self) -> ParallelismConfigurationDescriptionBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Default for ParallelismConfigurationDescriptionBuilder
impl Default for ParallelismConfigurationDescriptionBuilder
source§fn default() -> ParallelismConfigurationDescriptionBuilder
fn default() -> ParallelismConfigurationDescriptionBuilder
source§impl PartialEq for ParallelismConfigurationDescriptionBuilder
impl PartialEq for ParallelismConfigurationDescriptionBuilder
source§fn eq(&self, other: &ParallelismConfigurationDescriptionBuilder) -> bool
fn eq(&self, other: &ParallelismConfigurationDescriptionBuilder) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for ParallelismConfigurationDescriptionBuilder
Auto Trait Implementations§
impl Freeze for ParallelismConfigurationDescriptionBuilder
impl RefUnwindSafe for ParallelismConfigurationDescriptionBuilder
impl Send for ParallelismConfigurationDescriptionBuilder
impl Sync for ParallelismConfigurationDescriptionBuilder
impl Unpin for ParallelismConfigurationDescriptionBuilder
impl UnwindSafe for ParallelismConfigurationDescriptionBuilder
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