Struct IpMappingCoProcessFunction 

pub struct IpMappingCoProcessFunction { /* private fields */ }

Implementations

impl IpMappingCoProcessFunction

pub fn new(fn_schema: FnSchema) -> Self

Trait Implementations

impl CheckpointFunction for IpMappingCoProcessFunction

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 CoProcessFunction for IpMappingCoProcessFunction

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

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

This method is called for each element in the first of the connected streams.

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

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

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

impl Debug for IpMappingCoProcessFunction

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl NamedFunction for IpMappingCoProcessFunction

fn name(&self) -> &str