Trait datafusion::physical_plan::streaming::PartitionStream

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

A partition that can be converted into a SendableRecordBatchStream

Required Methods

fn schema(&self) -> &SchemaRef

Returns the schema of this partition

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

Returns a stream yielding this partitions values

Implementors