Module vec 

Extension methods and implementations for streams of vector containers.

These methods operate on containers that are vectors of individual items, and much of their behavior can be described item-by-item.

Vector containers are a natural entry point before one forms a stronger opinion on the containers one would like to use. While they are easy to use, vector containers (and owned data) invite performance antipatterns around resource management (allocation and deallocation, across threads).

Re-exports

pub use self::input::Input;

pub use self::unordered_input::UnorderedInput;

pub use self::partition::Partition;

pub use self::map::Map;

pub use self::filter::Filter;

pub use self::broadcast::Broadcast;

pub use self::to_stream::ToStream;

Modules

broadcast

Broadcast records to all workers.

filter

Filters a stream by a predicate.

input

Create new Streams connected to external inputs.

map

Extension methods for StreamVec based on record-by-record transformation.

partition

Partition a stream of records into multiple streams.

to_stream

Conversion to the StreamVec type from iterators.

unordered_input

Create new Streams connected to external inputs.