Skip to main content

BatchSink

rivet_cli::source

Trait BatchSink 

Source 
pub trait BatchSink {
    // Required methods
    fn on_schema(&mut self, schema: SchemaRef) -> Result<()>;
    fn on_batch(&mut self, batch: &RecordBatch) -> Result<()>;
}
Expand description

Receives schema and batches from a source, one at a time.

Required Methods§

Source

fn on_schema(&mut self, schema: SchemaRef) -> Result<()>

Source

fn on_batch(&mut self, batch: &RecordBatch) -> Result<()>

Implementors§