Driver for timely/differential dataflow.
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.
An interactive dataflow server.
Types related to the creation of dataflow sources.
Configures a dataflow server.
Predicates partitioned into temporal and non-temporal.
Information from timely dataflow workers.
All data and metadata messages that can be sent by dataflow workers or coordinator to the cacher thread.
Explicit instructions for timely dataflow workers.
Responses the worker can provide back to the coordinator.
Initiates a timely dataflow computation, processing materialized commands.