Module timely::dataflow::stream

A handle to a typed stream of timely data.

Most high-level timely dataflow programming is done with streams, which are each a handle to an operator output. Extension methods on the Stream type provide the appearance of higher-level declarative programming, while constructing a dataflow graph underneath.

Structs

• StreamCore
  Abstraction of a stream of C: Container records timestamped with S::Timestamp.

Traits

• AsStream
  A type that can be translated to a StreamCore.

Type Aliases

• Stream
  A stream batching data in vectors.