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§
fn on_schema(&mut self, schema: SchemaRef) -> Result<()>
fn on_batch(&mut self, batch: &RecordBatch) -> Result<()>
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".