Trait rlink::api::checkpoint::CheckpointFunction[−][src]

pub trait CheckpointFunction where
    Self: Debug, {
    fn initialize_state(
        &mut self, 
        context: &FunctionSnapshotContext, 
        handle: &Option<CheckpointHandle>
    );
    fn snapshot_state(
        &mut self, 
        context: &FunctionSnapshotContext
    ) -> CheckpointHandle;
}

Required methods

`fn initialize_state( &mut self, context: &FunctionSnapshotContext, handle: &Option<CheckpointHandle> )`[src]

trigger the method when a operator initialization

`fn snapshot_state( &mut self, context: &FunctionSnapshotContext ) -> CheckpointHandle`[src]

trigger the method when the operator operate a Barrier event

Loading content...

Implementors

Loading content...