Crate dataflow[−][src]
Driver for timely/differential dataflow.
Modules
| arrangement | Types related to the arrangement and management of collections. |
| decode | |
| logging | Logging dataflows for events generated by various subsystems. |
| metrics | |
| operator | |
| render | Renders a plan into a timely/differential dataflow computation. |
| server | An interactive dataflow server. |
| sink | |
| source | Types related to the creation of dataflow sources. |
Structs
| Config | Configures a dataflow server. |
| FilterPlan | Predicates partitioned into temporal and non-temporal. |
| WorkerFeedbackWithMeta | Information from timely dataflow workers. |
Enums
| CacheMessage | All data and metadata messages that can be sent by dataflow workers or coordinator to the cacher thread. |
| SequencedCommand | Explicit instructions for timely dataflow workers. |
| WorkerFeedback | Responses the worker can provide back to the coordinator. |
Functions
| serve | Initiates a timely dataflow computation, processing materialized commands. |