TimelyDataflow / timely-dataflow

A modular implementation of timely dataflow in Rust
MIT License
3.25k stars 273 forks source link

Move `capture/` to `core::capture/` #557

Closed frankmcsherry closed 5 months ago

frankmcsherry commented 5 months ago

The capture module is both pretty deep in the internals, and also not strongly opinionated about containers. The only nit was around Extract which needed some attention to normalize the shape of the output data (e.g. consolidate data by timestamp). Some external types need to be updated from element type to container type, but this looks like adding Vec<_> around the element type; one line in DD.