Module temporal_bucket

Source
Expand description

Utilities and stream extensions for temporal bucketing.

Structsยง

CapturingBuilder ๐Ÿ”’
MergeBatcherWrapper ๐Ÿ”’
A wrapper around MergeBatcher that implements the Storage trait for bucketing.

Traitsยง

TemporalBucketing
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.