Crate mz_timely_util

Utilities for working with Timely.

Modules

activator

Utilities to activate dataflows based on external triggers.

builder_async

Types to build async operators with general shapes.

event

Traits and types for describing captured timely dataflow streams.

operator

Common operator transformations on timely streams and differential collections.

operators_async_ext

Extensions for OperatorBuilder to create async operators.

progress

Utilities for working with Timely progress tracking.

replay

Traits and types for replaying captured timely dataflow streams.

Macros

async_op

Convenience macro used to wrap what might otherwise be the argument to build_reschedule.