Expand description
Common operator transformations on timely streams and differential collections.
Structs§
- Consolidating
Batcher - Accumulates updates into sorted, consolidated chains, and releases what a frontier unblocks.
Traits§
- Batcher
New - A batcher that generic code can construct.
- Clear
Container - A trait for containers that can be cleared.
- Collection
Ext - Extension methods for differential
Collections. - Concatenate
Flatten - Merge the contents of multiple streams and combine the containers using a container builder.
- Stream
Ext - Extension methods for timely
Streams.
Functions§
- consolidate_
pact - Aggregates the weights of equal records into at most one record.