Module streaming

Source
Expand description

Generic plans for deferred execution: StreamingTableExec and PartitionStream

Structs§

StreamingTableExec
An ExecutionPlan for one or more PartitionStreams.

Traits§

PartitionStream
A partition that can be converted into a SendableRecordBatchStream