Skip to content

Instantly share code, notes, and snippets.

@markusdybeck

markusdybeck/ThreadPoolForSpliterator.java

Created September 16, 2020 09:18
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save markusdybeck/b825bd9b627c8ed96f3fb4050e9cd80f to your computer and use it in GitHub Desktop.
Save markusdybeck/b825bd9b627c8ed96f3fb4050e9cd80f to your computer and use it in GitHub Desktop.
Download ZIP
Raw
ThreadPoolForSpliterator.java
threadPool.submit() -> {
Spliterator<T> spliterator = EsSpliterator.from(index, query, batchSize, documentClass, slices)
StreamSupport.stream(spliterator, true)
.forEach(batch -> handle(batch));
}.get();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment