Trait datafusion::physical_plan::streaming::PartitionStream

source · 
pub trait PartitionStream: Send + Sync {
    // Required methods
    fn schema(&self) -> &SchemaRef;
    fn execute(&self, ctx: Arc<TaskContext>) -> SendableRecordBatchStream;
}
Expand description

A partition that can be converted into a SendableRecordBatchStream

Required Methods§

source

fn schema(&self) -> &SchemaRef

Returns the schema of this partition

source

fn execute(&self, ctx: Arc<TaskContext>) -> SendableRecordBatchStream

Returns a stream yielding this partitions values

Implementors§