vec_source

rlink::functions::source::vec_input_format

Function vec_source 

Source 
pub fn vec_source(
    data: Vec<Record>,
    schema: Schema,
    parallelism: u16,
) -> IteratorInputFormat<impl FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>>