TimelyDataflow / differential-dataflow

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

Another attempt at introducing a columnated merge batcher #418

Closed antiguru closed 9 months ago

antiguru commented 10 months ago

This builds on #414 but uses the new Layout feature recently merged.

frankmcsherry commented 9 months ago

I have another question too: could the merger be for arbitrary BatchContainer types, or does it just work for TimelyStack? Is there some BC::prefered_capacity() method we might add to make it general?

antiguru commented 9 months ago

I have another question too: could the merger be for arbitrary BatchContainer types, or does it just work for TimelyStack? Is there some BC::prefered_capacity() method we might add to make it general?

I'd prefer a single general implementation, but it's not easy to get there:

frankmcsherry commented 9 months ago

Looks good, and let's merge!