Module mz_timely_util::operator

Common operator transformations on timely streams and differential collections.

Traits

• CollectionExt
  Extension methods for differential Collections.
• StreamExt
  Extension methods for timely Streams.

Functions

• consolidate_pact
  Aggregates the weights of equal records into at most one record.
• source_async
  Creates a new async data stream source for a scope.