Multi-stream: bounded top-K with a heap collector

sorted().limit(k) has to materialise and sort everything. A min-heap of size k keeps only k rows in memory no matter how long the feed is - which is the difference between a report and an OutOfMemoryError.

Full code & output

This topic is available to signed-in members.