Expand description
A Batcher
implementation based on merge sort.
The MergeBatcher
requires support from two types, a “chunker” and a “merger”.
The chunker receives input batches and consolidates them, producing sorted output
“chunks” that are fully consolidated (no adjacent updates can be accumulated).
The merger implements the Merger
trait, and provides hooks for manipulating
sorted “chains” of chunks as needed by the merge batcher: merging chunks and also
splitting them apart based on time.
Implementations of MergeBatcher
can be instantiated through the choice of both
the chunker and the merger, provided their respective output and input types align.
Re-exports§
Modules§
- A general purpose
Merger
implementation for arbitrary containers.
Structs§
- Creates batches from containers of unordered tuples.
Traits§
- A trait to describe interesting moments in a merge batcher.