Module mz_timely_util::operator

Common operator transformations on timely streams and differential collections.

Structs

• ConsolidateBuilder 🔒
  A builder that wraps a session for direct output to a stream.

Traits

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

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.