Expand description
Stream wrappers for physical operators
Structs§
- Batch
Split Stream - Stream wrapper that splits large
RecordBatches into smaller batches. - Empty
Record Batch Stream EmptyRecordBatchStreamcan be used to create aRecordBatchStreamthat will produce no results- Record
Batch Receiver Stream Builder - Builder for
RecordBatchReceiverStreamthat propagates errors and panic’s correctly. - Record
Batch Stream Adapter - Combines a [
Stream] with aSchemaRefimplementingSendableRecordBatchStreamfor the combination