Module datafusion::physical_plan::stream

Stream wrappers for physical operators

Structs

• RecordBatchReceiverStream
  A SendableRecordBatchStream that combines RecordBatches from multiple inputs, on new tokio Tasks, increasing the potential parallelism.
• RecordBatchReceiverStreamBuilder
  Builder for RecordBatchReceiverStream that propagates errors and panic’s correctly.
• RecordBatchStreamAdapter
  Combines a [Stream] with a SchemaRef implementing RecordBatchStream for the combination