Trait rlink::api::checkpoint::CheckpointFunction

pub trait CheckpointFunction {
    fn consult_version(
        &mut self, 
        context: &FunctionSnapshotContext, 
        _handle: &Option<CheckpointHandle>
    ) -> CheckpointId { ... }
    fn initialize_state(
        &mut self, 
        _context: &FunctionSnapshotContext, 
        _handle: &Option<CheckpointHandle>
    ) { ... }
    fn snapshot_state(
        &mut self, 
        _context: &FunctionSnapshotContext
    ) -> Option<CheckpointHandle> { ... }
}

Provided methods

fn consult_version(
    &mut self,
    context: &FunctionSnapshotContext,
    _handle: &Option<CheckpointHandle>
) -> CheckpointId

fn initialize_state(
    &mut self,
    _context: &FunctionSnapshotContext,
    _handle: &Option<CheckpointHandle>
)

trigger the method when a operator initialization

fn snapshot_state(
    &mut self,
    _context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>

trigger the method when the operator operate a Barrier event

Loading content...

Implementors

impl CheckpointFunction for SlidingEventTimeWindows

impl CheckpointFunction for BroadcastFlagMapFunction

impl CheckpointFunction for RoundRobinFlagMapFunction

impl CheckpointFunction for SchemaBaseKeySelector

impl CheckpointFunction for PrintOutputFormat

impl CheckpointFunction for SchemaBaseTimestampAssigner

impl<E> CheckpointFunction for BoundedOutOfOrdernessTimestampExtractor<E> where
    E: TimestampAssigner, 

Loading content...