Skip to main content

timely/dataflow/operators/vec/
mod.rs

1//! Extension methods and implementations for streams of vector containers.
2//!
3//! These methods operate on containers that are vectors of individual items,
4//! and much of their behavior can be described item-by-item.
5//!
6//! Vector containers are a natural entry point before one forms a stronger
7//! opinion on the containers one would like to use. While they are easy to
8//! use, vector containers (and owned data) invite performance antipatterns
9//! around resource management (allocation and deallocation, across threads).
10
11pub mod input;
12pub mod flow_controlled;
13pub mod unordered_input;
14pub mod partition;
15pub mod map;
16pub mod filter;
17pub mod delay;
18pub mod broadcast;
19pub mod to_stream;
20pub mod branch;
21pub mod result;
22pub mod aggregation;
23pub mod count;
24
25pub use self::input::Input;
26pub use self::unordered_input::UnorderedInput;
27pub use self::partition::Partition;
28pub use self::map::Map;
29pub use self::filter::Filter;
30pub use self::delay::Delay;
31pub use self::broadcast::Broadcast;
32pub use self::branch::{Branch, BranchWhen};
33pub use self::result::ResultStream;
34pub use self::to_stream::ToStream;