search

TimelyDataflow / differential-dataflow

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

dogsdogsdogs/lookup_map: Add unsafe variant #337

Closed antiguru closed 2 years ago

antiguru commented 3 years ago

Add an unsafe variant of the lookup_map operator in the spirit of #326.

The implementation relies on two function, where one consumes the output of map_times and the other one produces actual stream data. I'm not particularly happy about this design because it makes it cumbersome to share data between the two functions, but it seems to do the job.

Alternatives include passing an explicit shared piece of data to the functions, or provide direct access to the cursor and storage.

Signed-off-by: Moritz Hoffmann antiguru@gmail.com

antiguru commented 2 years ago

We probably don't want this, closing.