Trait rlink::api::checkpoint::CheckpointFunction [−][src]
Provided methods
fn consult_version(
&mut self,
context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
) -> CheckpointId
[src]
&mut self,
context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
) -> CheckpointId
fn initialize_state(
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
[src]
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
trigger the method when a operator
initialization
fn snapshot_state(
&mut self,
_context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>
[src]
&mut self,
_context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>
trigger the method when the operator
operate a Barrier
event
Implementors
impl CheckpointFunction for SlidingEventTimeWindows
[src]
impl CheckpointFunction for BroadcastFlagMapFunction
[src]
impl CheckpointFunction for RoundRobinFlagMapFunction
[src]
impl CheckpointFunction for SchemaBaseKeySelector
[src]
impl CheckpointFunction for PrintOutputFormat
[src]
impl CheckpointFunction for SchemaBaseTimestampAssigner
[src]
impl<E> CheckpointFunction for BoundedOutOfOrdernessTimestampExtractor<E> where
E: TimestampAssigner,
[src]
E: TimestampAssigner,