Module datafusion::physical_plan::stream

Stream wrappers for physical operators

Structs

• EmptyRecordBatchStream
  EmptyRecordBatchStream can be used to create a RecordBatchStream that will produce no results
• RecordBatchReceiverStreamBuilder
  Builder for [RecordBatchReceiverStream] that propagates errors and panic’s correctly.
• RecordBatchStreamAdapter
  Combines a [Stream] with a SchemaRef implementing RecordBatchStream for the combination