Trait rlink::core::function::FlatMapFunction [−][src]
pub trait FlatMapFunction where
Self: NamedFunction + CheckpointFunction, { 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>> { ... } }