Module 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