Expand description
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§
- Stream
Core - Abstraction of a stream of
C: Containerrecords timestamped withS::Timestamp.
Traits§
- AsStream
- A type that can be translated to a StreamCore.
Type Aliases§
- Stream
- A stream batching data in vectors.