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<()>; }
Required methods
fn open(&mut self, context: &Context) -> Result<()>
[src]
fn process_left(&mut self, record: Record) -> Box<dyn Iterator<Item = Record>>
[src]
Expand description
This method is called for each element in the first of the connected streams.
stream_seq
is the DataStream
index
fn process_right(
&mut self,
stream_seq: usize,
record: Record
) -> Box<dyn Iterator<Item = Record>>
[src]
&mut self,
stream_seq: usize,
record: Record
) -> Box<dyn Iterator<Item = Record>>