Driver for timely/differential dataflow.
Logging dataflows for events generated by various subsystems.
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.