Interface PojoMassEntitySink<E>

  • Type Parameters:
    E - The type of loaded entities.

    public interface PojoMassEntitySink<E>
    A sink for use by a PojoMassIdentifierLoader.
    • 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.

        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.