pub type AccountedChunkChainBatcher<D, T, R, G> = ConsolidatingBatcher<ChunkChunker<D, T, R, G>, AccountedChunkMerger<D, T, R, G>>;Expand description
The AccountedChunkBatcher of a caller that wants the merged chain rather
than a batch built from it, such as the temporal-bucket store.
Aliased Type§
pub struct AccountedChunkChainBatcher<D, T, R, G> {
chunker: ChunkChunker<D, T, R, G>,
ladder: MergeLadder<AccountedChunkMerger<D, T, R, G>>,
extractor: AccountedChunkMerger<D, T, R, G>,
stash: Vec<<AccountedChunkMerger<D, T, R, G> as Merger>::Chunk>,
frontier: Antichain<<AccountedChunkMerger<D, T, R, G> as Extractor>::Time>,
}Fields§
§chunker: ChunkChunker<D, T, R, G>Melds input containers into sorted, consolidated chunks.
ladder: MergeLadder<AccountedChunkMerger<D, T, R, G>>Sorted, consolidated chains, with their size accounting.
extractor: AccountedChunkMerger<D, T, R, G>Splits the merged chain at a frontier.
The ladder keeps its own merger private, so extraction uses a second instance.
stash: Vec<<AccountedChunkMerger<D, T, R, G> as Merger>::Chunk>Stash of empty chunks, recycled through extraction.
frontier: Antichain<<AccountedChunkMerger<D, T, R, G> as Extractor>::Time>The lower-bound frontier of the data retained after the last extract.