Trait rlink::core::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

Implementors

impl CheckpointFunction for RangeWindowFilter

impl CheckpointFunction for BroadcastFlagMapFunction

impl CheckpointFunction for RoundRobinFlagMapFunction

impl CheckpointFunction for SchemaKeySelector

impl CheckpointFunction for PrintOutputFormat

impl CheckpointFunction for DefaultWatermarkStrategy

impl CheckpointFunction for SlidingEventTimeWindows

impl<T> CheckpointFunction for IteratorInputFormat<T> where
    T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,