Module timely::dataflow::operators::capture::capture

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.