Trait rlink::api::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 flat_map_element(
        &mut self, 
        element: Element
    ) -> Box<dyn Iterator<Item = Element>> { ... }
}

Required methods

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

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

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

Loading content...

Provided methods

fn flat_map_element(
    &mut self,
    element: Element
) -> Box<dyn Iterator<Item = Element>>[src]

Loading content...

Implementors

impl FlatMapFunction for BroadcastFlagMapFunction[src]

impl FlatMapFunction for RoundRobinFlagMapFunction[src]

Loading content...