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

Combined with StreamingTableExec, you can use this trait to implement ExecutionPlan for a custom source with less boiler plate than implementing ExecutionPlan directly for many use cases.

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