Crate mz_timely_util

source ·
Expand description

Utilities for working with Timely.


  • Utilities to activate dataflows based on external triggers.
  • Types to build async operators with general shapes.
  • Traits and types for describing captured timely dataflow streams.
  • Common operator transformations on timely streams and differential collections.
  • Traits and types for partially ordered sets.
  • Parallelization contracts, describing requirements for data movement along dataflow edges.
  • Utilities for working with Timely progress tracking.
  • Notation
  • Traits and types for replaying captured timely dataflow streams.