Expand description

Driver for timely/differential dataflow.

Re-exports

pub use boundary::tcp_boundary;
pub use decode::metrics::DecodeMetrics;

Modules

Types and traits for communicating definite data from storage to compute.

This module provides functions that build decoding pipelines from raw source streams.

Renders a plan into a timely/differential dataflow computation.

server 🔒

An interactive dataflow server.

Types related to the creation of dataflow raw sources.

Worker-local state for storage timely instances.

Structs

Configures a dataflow server.

A boundary implementation that panics on use.

A handle to a running dataflow server.

Traits

A type that can replay specific sources

A type that can capture a specific source.

Functions

Initiates a timely dataflow computation, processing materialized commands.