Open xandkar opened 2 years ago
After #1334 is merged, the innards of data_stream:pmap_to_bag (which it introduces) can also be used to implement data_stream:piter and optionally parallelize the processing of the stream of blocks in a snap.
data_stream:pmap_to_bag
data_stream:piter
After #1334 is merged, the innards of
data_stream:pmap_to_bag(which it introduces) can also be used to implementdata_stream:piterand optionally parallelize the processing of the stream of blocks in a snap.