Module dataflow::server [−][src]
Expand description
An interactive dataflow server.
Modules
Prometheus metrics for our interactive dataflow server
Structs
Configures a dataflow server.
An in-progress peek, and data to eventually fulfill it.
A handle to a running dataflow server.
State maintained for each worker thread.
Statics
How frequently each dataflow worker sends timestamp binding updates back to the coordinator.
Functions
Initiates a timely dataflow computation, processing materialized commands.