Module timely::dataflow::operators::capture::capture
[−]
[src]
Traits and types for capturing timely dataflow streams.
All timely dataflow streams can be captured, but there are many ways to capture
these streams. A stream may be capture_into
'd any type implementing EventPusher
,
and there are several default implementations, including a linked-list, Rust's MPSC
queue, and a binary serializer wrapping any W: Write
.
Traits
Capture |
Capture a stream of timestamped data for later replay. |