Trait datafusion::physical_plan::streaming::PartitionStream

pub trait PartitionStream: Send + Sync {
    // Required methods
    fn schema(&self) -> &Arc<Schema>;
    fn execute(
        &self,
        ctx: Arc<TaskContext>,
    ) -> Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>;
}

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) -> &Arc<Schema>

Returns the schema of this partition

fn execute( &self, ctx: Arc<TaskContext>, ) -> Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>

Returns a stream yielding this partitions values

Implementors

impl PartitionStream for TestPartitionStream