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 SendableRecordBatchStream for the combination