Expand description
Utilities and stream extensions for temporal bucketing.
Structsยง
- Capturing
Builder ๐ - Merge
Batcher ๐Wrapper - A wrapper around
MergeBatcher
that implements theStorage
trait for bucketing.
Traitsยง
- Temporal
Bucketing - Sort outstanding updates into a
BucketChain
, and reveal data not in advance of the input frontier. Retains a capability at the last input frontier to retain the right to produce data at times between the last input frontier and the current input frontier.