Trait rlink::core::function::OutputFormat [−][src]
pub trait OutputFormat where
Self: NamedFunction + CheckpointFunction, { fn open(&mut self, context: &Context) -> Result<()>; fn write_record(&mut self, record: Record); fn close(&mut self) -> Result<()>; fn write_element(&mut self, element: Element) { ... } fn schema(&self, _input_schema: FnSchema) -> FnSchema { ... } }
Required methods
Opens a parallel instance of the output format to store the result of its parallel instance.
When this method is called, the output format it guaranteed to be configured.
taskNumber The number of the parallel instance.
numTasks The number of parallel tasks.