#[non_exhaustive]pub struct FlinkRunConfiguration {
pub allow_non_restored_state: Option<bool>,
}Expand description
Describes the starting parameters for a Flink-based Kinesis Data Analytics application.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.allow_non_restored_state: Option<bool>When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. This will happen if the program is updated between snapshots to remove stateful parameters, and state data in the snapshot no longer corresponds to valid application data. For more information, see Allowing Non-Restored State in the Apache Flink documentation.
This value defaults to false. If you update your application without specifying this parameter, AllowNonRestoredState will be set to false, even if it was previously set to true.
Implementations§
source§impl FlinkRunConfiguration
impl FlinkRunConfiguration
sourcepub fn allow_non_restored_state(&self) -> Option<bool>
pub fn allow_non_restored_state(&self) -> Option<bool>
When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. This will happen if the program is updated between snapshots to remove stateful parameters, and state data in the snapshot no longer corresponds to valid application data. For more information, see Allowing Non-Restored State in the Apache Flink documentation.
This value defaults to false. If you update your application without specifying this parameter, AllowNonRestoredState will be set to false, even if it was previously set to true.
source§impl FlinkRunConfiguration
impl FlinkRunConfiguration
sourcepub fn builder() -> FlinkRunConfigurationBuilder
pub fn builder() -> FlinkRunConfigurationBuilder
Creates a new builder-style object to manufacture FlinkRunConfiguration.
Trait Implementations§
source§impl Clone for FlinkRunConfiguration
impl Clone for FlinkRunConfiguration
source§fn clone(&self) -> FlinkRunConfiguration
fn clone(&self) -> FlinkRunConfiguration
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moresource§impl Debug for FlinkRunConfiguration
impl Debug for FlinkRunConfiguration
source§impl PartialEq for FlinkRunConfiguration
impl PartialEq for FlinkRunConfiguration
source§fn eq(&self, other: &FlinkRunConfiguration) -> bool
fn eq(&self, other: &FlinkRunConfiguration) -> bool
self and other values to be equal, and is used
by ==.