Driver for timely/differential dataflow.
Logging dataflows for events generated by various subsystems.
Types related to the creation of dataflow sources.
Information from timely dataflow workers.
All data and metadata messages that can be sent by dataflow workers or coordinator to the persister thread.
Explicit instructions for timely dataflow workers.
Responses the worker can provide back to the coordinator.
Initiates a timely dataflow computation, processing materialized commands.