Package org.hibernate.search.mapper.pojo.loading.spi

Interface PojoMassEntitySink<E>

Type Parameters:
E - The type of loaded entities.
public interface PojoMassEntitySink<E>
A sink for use by a PojoMassIdentifierLoader.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    accept(List<? extends E> batch)
    Adds a batch of entities to the sink.

  • Method Details

    • 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. Never null, never empty.
      Throws:
      InterruptedException - If the thread was interrupted while handling the batch. This exception should generally not be caught: just propagate it.