#[non_exhaustive]pub struct ParallelismConfigurationUpdateBuilder { /* private fields */ }
Expand description
A builder for ParallelismConfigurationUpdate
.
Implementations§
source§impl ParallelismConfigurationUpdateBuilder
impl ParallelismConfigurationUpdateBuilder
sourcepub fn configuration_type_update(self, input: ConfigurationType) -> Self
pub fn configuration_type_update(self, input: ConfigurationType) -> Self
Describes updates to whether the application uses the default parallelism for the Managed Service for Apache Flink service, or if a custom parallelism is used. You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
sourcepub fn set_configuration_type_update(
self,
input: Option<ConfigurationType>,
) -> Self
pub fn set_configuration_type_update( self, input: Option<ConfigurationType>, ) -> Self
Describes updates to whether the application uses the default parallelism for the Managed Service for Apache Flink service, or if a custom parallelism is used. You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
sourcepub fn get_configuration_type_update(&self) -> &Option<ConfigurationType>
pub fn get_configuration_type_update(&self) -> &Option<ConfigurationType>
Describes updates to whether the application uses the default parallelism for the Managed Service for Apache Flink service, or if a custom parallelism is used. You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
sourcepub fn parallelism_update(self, input: i32) -> Self
pub fn parallelism_update(self, input: i32) -> Self
Describes updates to the initial number of parallel tasks an 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 will reduce CurrentParallelism
down to the Parallelism
setting.
sourcepub fn set_parallelism_update(self, input: Option<i32>) -> Self
pub fn set_parallelism_update(self, input: Option<i32>) -> Self
Describes updates to the initial number of parallel tasks an 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 will reduce CurrentParallelism
down to the Parallelism
setting.
sourcepub fn get_parallelism_update(&self) -> &Option<i32>
pub fn get_parallelism_update(&self) -> &Option<i32>
Describes updates to the initial number of parallel tasks an 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 will reduce CurrentParallelism
down to the Parallelism
setting.
sourcepub fn parallelism_per_kpu_update(self, input: i32) -> Self
pub fn parallelism_per_kpu_update(self, input: i32) -> Self
Describes updates to the number of parallel tasks an application can perform per Kinesis Processing Unit (KPU) used by the application.
sourcepub fn set_parallelism_per_kpu_update(self, input: Option<i32>) -> Self
pub fn set_parallelism_per_kpu_update(self, input: Option<i32>) -> Self
Describes updates to the number of parallel tasks an application can perform per Kinesis Processing Unit (KPU) used by the application.
sourcepub fn get_parallelism_per_kpu_update(&self) -> &Option<i32>
pub fn get_parallelism_per_kpu_update(&self) -> &Option<i32>
Describes updates to the number of parallel tasks an application can perform per Kinesis Processing Unit (KPU) used by the application.
sourcepub fn auto_scaling_enabled_update(self, input: bool) -> Self
pub fn auto_scaling_enabled_update(self, input: bool) -> Self
Describes updates to whether the Managed Service for Apache Flink service can increase the parallelism of a Managed Service for Apache Flink application in response to increased throughput.
sourcepub fn set_auto_scaling_enabled_update(self, input: Option<bool>) -> Self
pub fn set_auto_scaling_enabled_update(self, input: Option<bool>) -> Self
Describes updates to whether the Managed Service for Apache Flink service can increase the parallelism of a Managed Service for Apache Flink application in response to increased throughput.
sourcepub fn get_auto_scaling_enabled_update(&self) -> &Option<bool>
pub fn get_auto_scaling_enabled_update(&self) -> &Option<bool>
Describes updates to whether the Managed Service for Apache Flink service can increase the parallelism of a Managed Service for Apache Flink application in response to increased throughput.
sourcepub fn build(self) -> ParallelismConfigurationUpdate
pub fn build(self) -> ParallelismConfigurationUpdate
Consumes the builder and constructs a ParallelismConfigurationUpdate
.
Trait Implementations§
source§impl Clone for ParallelismConfigurationUpdateBuilder
impl Clone for ParallelismConfigurationUpdateBuilder
source§fn clone(&self) -> ParallelismConfigurationUpdateBuilder
fn clone(&self) -> ParallelismConfigurationUpdateBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Default for ParallelismConfigurationUpdateBuilder
impl Default for ParallelismConfigurationUpdateBuilder
source§fn default() -> ParallelismConfigurationUpdateBuilder
fn default() -> ParallelismConfigurationUpdateBuilder
source§impl PartialEq for ParallelismConfigurationUpdateBuilder
impl PartialEq for ParallelismConfigurationUpdateBuilder
source§fn eq(&self, other: &ParallelismConfigurationUpdateBuilder) -> bool
fn eq(&self, other: &ParallelismConfigurationUpdateBuilder) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for ParallelismConfigurationUpdateBuilder
Auto Trait Implementations§
impl Freeze for ParallelismConfigurationUpdateBuilder
impl RefUnwindSafe for ParallelismConfigurationUpdateBuilder
impl Send for ParallelismConfigurationUpdateBuilder
impl Sync for ParallelismConfigurationUpdateBuilder
impl Unpin for ParallelismConfigurationUpdateBuilder
impl UnwindSafe for ParallelismConfigurationUpdateBuilder
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