Crate declarative_dataflow

Declarative dataflow infrastructure

This crate contains types, traits, and logic for assembling differential dataflow computations from declaratively specified programs, without any additional compilation.

Re-exports

pub use binding::AsBinding;

pub use binding::AttributeBinding;

pub use binding::Binding;

pub use plan::Hector;

pub use plan::ImplContext;

pub use plan::Implementable;

pub use plan::Plan;

pub use timestamp::Rewind;

pub use timestamp::Time;

Modules

binding

Binding language, mainly for use in Hector-powered plans.

domain

Logic for working with attributes under a shared timestamp semantics.

logging

Loggers and logging events for declarative dataflow.

operators

Extension traits for Stream implementing various declarative-specific operators.

plan

Types and traits for implementing query plans.

server

Server logic for driving the library via commands.

sinks

Types and operators to feed outputs into external systems.

sources

Types and operators to work with external data sources.

timestamp

Various timestamp implementations.

Structs

AttributeConfig

Per-attribute semantics.

CollectionRelation

A collection and variable bindings.

Error

A client-facing, non-exceptional error.

RelationConfig

Per-relation semantics.

Rule

A named relation.

ShutdownHandle

A wrapper around a vector of ShutdownButton’s. Ensures they will be pressed on dropping the handle.

TxData

Transaction data.

Enums

Implemented

@TODO

IndexDirection

Attributes can be indexed in two ways, once from eid to value and the other way around. More powerful query capabilities may rely on both directions being available, whereas simple queries, such as star-joins and pull queries, might get by with just a forward index.

InputSemantics

Attribute indices can have various operations applied to them, based on their semantics.

Output

Anything that can be returned to clients.

QuerySupport

Attributes might only appear in certain classes of queries. If that is the case, indexing overhead can be reduced.

Value

Possible data values.

Functions

collect_dependencies

Returns a deduplicates list of all rules used in the definition of the specified names. Includes the specified names.

implement

Takes a query plan and turns it into a differential dataflow.

implement_neu

@TODO

q

Helper function to create a query plan. The resulting query will provide values for the requested target variables, under the constraints expressed by the bindings provided.

Type Aliases

Aid

A unique attribute identifier.

Client

A worker-local client connection identifier.

Eid

A unique entity identifier.

Rational32

Alias for a Ratio of 32-bit-sized integers.

RelationHandle

A handle to an arranged relation.

ResultDiff

A (tuple, time, diff) triple, as sent back to clients.

TraceKeyHandle

A trace of values indexed by self.

TraceValHandle

A trace of (K, V) pairs indexed by key.