Package ca.uhn.fhir.jpa.util

Class QueryChunker<T>

java.lang.Object

ca.uhn.fhir.util.TaskChunker<T>

ca.uhn.fhir.jpa.util.QueryChunker<T>

public class QueryChunker<T>
extends TaskChunker<T>

As always, Oracle can't handle things that other databases don't mind.. In this case it doesn't like more than ~1000 IDs in a single load, so we break this up if it's lots of IDs. I suppose maybe we should be doing this as a join anyhow but this should work too. Sigh.

Constructor Summary

Constructors

Constructor	Description
QueryChunker()

Method Summary

Modifier and Type	Method	Description
static <T> void	chunk(Collection<T> theInput, Consumer<List<T>> theBatchConsumer)
static <T> Stream<List<T>>	chunk(Stream<T> theStream)

Methods inherited from class ca.uhn.fhir.util.TaskChunker

chunk, chunk, chunk, chunk

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueryChunker

public QueryChunker()

Method Details

chunk

public static <T> void chunk(Collection<T> theInput,
 Consumer<List<T>> theBatchConsumer)

chunk

public static <T> Stream<List<T>> chunk(Stream<T> theStream)