Module timely::dataflow::operators::core

Extension traits for StreamCore implementing various operators that are independent of specific container types.

Re-exports

• pub use capture::Capture;
• pub use concat::Concat;
• pub use concat::Concatenate;
• pub use enterleave::Enter;
• pub use enterleave::Leave;
• pub use exchange::Exchange;
• pub use feedback::Feedback;
• pub use feedback::LoopVariable;
• pub use feedback::ConnectLoop;
• pub use filter::Filter;
• pub use input::Input;
• pub use inspect::Inspect;
• pub use inspect::InspectCore;
• pub use map::Map;
• pub use ok_err::OkErr;
• pub use partition::Partition;
• pub use probe::Probe;
• pub use to_stream::ToStream;
• pub use to_stream::ToStreamBuilder;
• pub use reclock::Reclock;
• pub use unordered_input::UnorderedInput;
• pub use unordered_input::UnorderedHandle;

Modules

• capture
  Operators to capture and replay timely dataflow streams.
• concat
  Merges the contents of multiple streams.
• enterleave
  Extension traits to move a Stream between an outer Scope and inner Scope.
• exchange
  Exchange records between workers.
• feedback
  Create cycles in a timely dataflow graph.
• filter
  Filters a stream by a predicate.
• input
  Create new Streams connected to external inputs.
• inspect
  Extension trait and implementation for observing and action on streamed data.
• map
  Extension methods for StreamCore based on record-by-record transformation.
• ok_err
  Operators that separate one stream into two streams based on some condition
• partition
  Partition a stream of records into multiple streams.
• probe
  Monitor progress at a Stream.
• rc
  Shared containers
• reclock
  Extension methods for Stream based on record-by-record transformation.
• to_stream
  Conversion to the StreamCore type from iterators.
• unordered_input
  Create new StreamCores connected to external inputs.