Java 8 Stream with batch processing

by

For completeness, here is a Guava solution.

Iterators.partition(stream.iterator(), batchSize).forEachRemaining(this::process);

In the question the collection is available so a stream isn’t needed and it can be written as,

Iterables.partition(data, batchSize).forEach(this::process);

More Related Contents:

  1. Custom thread pool in Java 8 parallel stream
  2. Java 8 Iterable.forEach() vs foreach loop
  3. What’s the difference between map() and flatMap() methods in Java 8?
  4. Java 8 lambdas, Function.identity() or t->t
  5. Java 8: performance of Streams vs Collections
  6. Can you split a stream into two streams?
  7. Why does parallel stream with lambda in static initializer cause a deadlock?
  8. Java 8 Streams FlatMap method example
  9. Parallel streams, collectors and thread safety
  10. Java 8 lambdas group list into map
  11. Java 8, Streams to find the duplicate elements
  12. Fetch first element of stream matching the criteria
  13. forEach vs forEachOrdered in Java 8 Stream
  14. Java 8: How do I work with exception throwing methods in streams?
  15. Why does Iterable not provide stream() and parallelStream() methods?
  16. Java Streams: How to do an efficient “distinct and sort”?
  17. stream on JPA lazy list
  18. How does combiner in Stream.collect method work in java 8?
  19. How can I throw CHECKED exceptions from inside Java 8 lambdas/streams?
  20. How to apply multiple predicates to a java.util.Stream?
  21. Java8: HashMap to HashMap using Stream / Map-Reduce / Collector
  22. Parallel stream from a HashSet doesn’t run in parallel
  23. How to short-circuit a reduce() operation on a Stream?
  24. How to get a Stream from a float[]
  25. Difference between findAny() and findFirst() in Java 8
  26. Want to create a stream of characters from char array in java
  27. Non-interference exact meaning in Java 8 streams
  28. Does collect operation on Stream close the stream and underlying resources?
  29. How to get multiple values from an object using a single stream operation?
  30. non-interference requirement on Java 8 streams

Leave a Comment