Module stream 

Stream wrappers for physical operators

Structs

BatchSplitStream

Stream wrapper that splits large [RecordBatch]es into smaller batches.

EmptyRecordBatchStream

EmptyRecordBatchStream can be used to create a RecordBatchStream that will produce no results

ObservedStream 🔒

Stream wrapper that records BaselineMetrics for a particular [SendableRecordBatchStream] (likely a partition)

ReceiverStreamBuilder 🔒

Creates a stream from a collection of producing tasks, routing panics to the stream.

RecordBatchReceiverStreamBuilder

Builder for RecordBatchReceiverStream that propagates errors and panic’s correctly.

RecordBatchStreamAdapter

Combines a [Stream] with a [SchemaRef] implementing SendableRecordBatchStream for the combination