Crate dataflow[][src]

Expand description

Driver for timely/differential dataflow.


Utilities to activate dataflows based on external triggers.

Types related to the arrangement and management of collections.

Logging dataflows for events generated by various subsystems.

Renders a plan into a timely/differential dataflow computation.

Traits and types for replaying captured timely dataflow streams.

An interactive dataflow server.

Types related to the creation of dataflow sources.


Configures a dataflow server.

Information from timely dataflow workers.

Data about timestamp bindings that dataflow workers send to the coordinator


Explicit instructions for timely dataflow workers.

A rendering plan with all conditional logic removed.

Responses the worker can provide back to the coordinator.


Initiates a timely dataflow computation, processing materialized commands.