Multi-stream: a custom Collector that aggregates joined rows

When a group needs several numbers at once, Collector.of beats three passes. The mutable accumulator is a long[], the combiner is what makes it safe to parallelise, and the finisher turns it into a record nobody can corrupt.

Full code & output

This topic is available to signed-in members.