Structs§
- Field
Cursor Stream - Specialized stream for sorts on single primitive columns
- Fused
Streams 🔒 - A new type wrapper around a set of fused
SendableRecordBatchStreamthat implements debug, and skips over empty [RecordBatch] - Reusable
Rows 🔒 - A pair of
Arc<Rows>that can be reused - RowCursor
Stream - A
PartitionedStreamthat wraps a set ofSendableRecordBatchStreamand computesRowValuesbased on the providedPhysicalSortExprNote: the stream returns an error if the consumer buffers more than one RowValues (i.e. holds on to two RowValues from the same partition at the same time).
Traits§
- Partitioned
Stream - A
Streamthat has multiple partitions that can be polled separately but not concurrently