Crate mz_timely_util
source · [−]Expand description
Utilities for working with Timely
Modules
Utilities to activate dataflows based on external triggers.
Traits and types for describing captured timely dataflow streams.
Common operator transformations on timely streams and differential collections.
Extensions for OperatorBuilder to create async operators.
Traits and types for replaying captured timely dataflow streams.
Macros
Convenience macro used to wrap what might otherwise be the argument to build_reschedule.