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

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

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

    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;
}

Required methods

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

stream_seq is the DataStream index

Implementors