Struct BroadcastFlagMapFunction 

pub struct BroadcastFlagMapFunction { /* private fields */ }

Implementations

impl BroadcastFlagMapFunction

pub fn new() -> Self

Trait Implementations

impl CheckpointFunction for BroadcastFlagMapFunction

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

impl FlatMapFunction for BroadcastFlagMapFunction

fn open(&mut self, context: &Context) -> Result<()>

fn flat_map(&mut self, record: Record) -> Box<dyn Iterator<Item = Record>>

fn close(&mut self) -> Result<()>

fn schema(&self, input_schema: FnSchema) -> FnSchema

fn flat_map_element( &mut self, element: Element, ) -> Box<dyn Iterator<Item = Element>>

impl NamedFunction for BroadcastFlagMapFunction

fn name(&self) -> &str