Interface PojoMassEntitySink<E>
-
- Type Parameters:
E
- The type of loaded entities.
public interface PojoMassEntitySink<E>
A sink for use by aPojoMassIdentifierLoader
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
accept(List<? extends E> batch)
Adds a batch of entities to the sink.
-
-
-
Method Detail
-
accept
void accept(List<? extends E> batch) throws InterruptedException
Adds a batch of entities to the sink.The list and entities need to stay usable at least until this method returns, as they will be consumed synchronously. Afterwards, they can be discarded or reused at will.
- Parameters:
batch
- The next batch of identifiers. Nevernull
, never empty.- Throws:
InterruptedException
- If the thread was interrupted while handling the batch. This exception should generally not be caught: just propagate it.
-
-