Module merge 

Merge that deals with an arbitrary size of streaming inputs. This is an order-preserving merge.

Structs

SortPreservingMergeStream 🔒

Merges a stream of sorted cursors and record batches into a single sorted stream

Type Aliases

CursorStream 🔒

A fallible PartitionedStream of Cursor and [RecordBatch]