Expand description
Specialize differential dataflow operators.
Differential dataflow introduces a small number of specialized operators on collections. These
operators have specialized implementations to make them work efficiently, and are in addition
to several operations defined directly on the Collection type (e.g. map and filter).
Re-exports§
pub use self::iterate::Iterate;pub use self::count::CountTotal;pub use self::threshold::ThresholdTotal;
Modules§
- arrange
- Types and traits for arranging collections.
- common
- Types and methods generally useful for differential computation.
- count
- Count the number of occurrences of each element.
- int_
proxy - Backend-agnostic operator tactics using integer proxies.
- iterate
- Iterative application of a differential dataflow fragment.
- join
- Match pairs of records based on a key.
- reduce
- Applies a reduction function on records grouped by key.
- threshold
- Reduce the collection to one occurrence of each distinct element.
Structs§
- Edit
List - An accumulation of (value, time, diff) updates.
- Value
History - A loaded, time-ordered replay of one key’s
(value, time, diff)edits, with meet-advanced buffer collapse — the shared machinery under the cursor reduce, theint_proxytactics, and thecommonhelpers. Its local contract: afteradvance_buffer_by(meet)with the meet of the un-replayed times, the buffer is consolidated and replay cost stays linear in edits rather than quadratic.