- Type Parameters:
I- The type of entity identifiers.
public interface PojoMassIdentifierSink<I>A sink for use by a
void accept(List<? extends I> batch) throws InterruptedExceptionAdds a batch of identifiers to the sink.
Identifiers can be passed in any order, but the caller must ensure that a given identifier is never passed more than once, even across multiple calls to this method.
The list only needs to stay usable until this method returns, as it will be copied. Afterwards, it can be discarded or reused at will. The identifiers themselves, however, must not change after this method is called, because they will be consumed asynchronously.
batch- The next batch of identifiers. Never
null, never empty.
InterruptedException- If the thread was interrupted while handling the batch. This exception should generally not be caught: just propagate it.
void complete()Signals that no more identifiers are available.