TimelyDataflow / differential-dataflow

An implementation of differential dataflow using timely dataflow on Rust.
MIT License
2.51k stars 182 forks source link

Use consolidating builder in consolidate_stream #488

Closed antiguru closed 2 months ago

antiguru commented 2 months ago

This switches from consolidating each input individually to consolidating at the output. The benefits are that it can yield better consolidation performance because it can consolidate across input containers instead of only being able to consolidate each individual input container.