Trait ResultSink 

pub trait ResultSink {
    // Required methods
    fn no_result(&mut self, rows_affected: Option<u64>) -> Result<()>;
    fn begin(&mut self, schema: SchemaRef) -> Result<()>;
    fn batch(&mut self, batch: RecordBatch) -> Result<bool>;
}

Where a source pushes the outcome of execute: either no_result, or begin followed by any number of batch calls.

Required Methods

fn no_result(&mut self, rows_affected: Option<u64>) -> Result<()>

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

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

Returns false once the row limit is reached: stop producing batches.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors