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

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

    fn record_iter(&mut self) -> Box<dyn Iterator<Item = Record> + Send>;

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

    fn element_iter(&mut self) -> Box<dyn Iterator<Item = Element> + Send> { ... }
}
Expand description

The base interface for data sources that produces records.

Required methods

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

fn record_iter(&mut self) -> Box<dyn Iterator<Item = Record> + Send>[src]

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

Loading content...

Provided methods

fn element_iter(&mut self) -> Box<dyn Iterator<Item = Element> + Send>[src]

Loading content...

Implementors

Loading content...