Trait Context 

pub trait Context: Send {
    // Required methods
    fn collect(&mut self, record: Record);
    fn watermark(&mut self, wm: Watermark);
    fn kv(&self) -> Arc<dyn KvState>;
    fn timers(&self) -> Arc<dyn Timers>;
}

Execution context visible to Sources and Operators.

Required Methods

fn collect(&mut self, record: Record)

fn watermark(&mut self, wm: Watermark)

fn kv(&self) -> Arc<dyn KvState>

fn timers(&self) -> Arc<dyn Timers>

Implementors