Trait rlink::api::function::CoProcessFunction[−][src]

pub trait CoProcessFunction where
    Self: NamedFunction + CheckpointFunction, {
    fn open(&mut self, context: &Context) -> Result<()>;

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

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

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

Required methods

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

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

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

stream_seq is the DataStream index

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

fn close(&mut self) -> Result<()>[src]

Loading content...

Implementors

Loading content...