Module temporal_bucket

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.