Skip to main content Module flat_merge Copy item path Source BatchBuilder Provides an API to incrementally build a [RecordBatch] from partitioned [RecordBatch] BatchCursor 🔒 Keeps track of the current position in a batch FlatMergeIterator Iterator to merge multiple sorted iterators into a single sorted iterator. FlatMergeReader Iterator to merge multiple sorted iterators into a single sorted iterator. GenericNode 🔒 A sync node in the merge iterator. MergeAlgo 🔒 Common algorithm of merging sorted batches from multiple nodes. MergeMetrics Metrics for the merge reader. RowCursor 🔒 Cursor to a row in the [RecordBatch]. SortColumns 🔒 Columns to compare for a [RecordBatch]. MergeMetricsReport Trait for reporting merge metrics. NodeCmp 🔒 A comparable node of the heap. check_interleave_bytes_overflow 🔒 Checks whether interleaving the selected rows from byte columns would overflow
i32 offsets. Similar to arrow-rs interleave_bytes(), accumulates offsets and
returns an error if the capacity exceeds i32::MAX. check_interleave_overflow 🔒 Checks whether interleave() would overflow i32 offsets for Utf8 or Binary columns. IterNode 🔒 StreamNode 🔒