[][src]Crate dataflow

Driver for timely/differential dataflow.

Modules

logging

Logging dataflows for events generated by various subsystems.

source

Types related to the creation of dataflow sources.

Structs

BroadcastToken

A comm::broadcast::Token that permits broadcasting commands to the Timely workers.

WorkerFeedbackWithMeta

Information from timely dataflow workers.

Enums

PersistenceMessage

All data and metadata messages that can be sent by dataflow workers or coordinator to the persister 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.