Interface PojoMassIdentifierLoader

All Superinterfaces:

public interface PojoMassIdentifierLoader extends AutoCloseable
A loader of entity identifiers in batch, used in particular for mass indexing.
  • Method Details

    • close

      void close()
      Specified by:
      close in interface AutoCloseable
    • totalCount

      long totalCount()
      The total count of identifiers expected to be loaded.
    • loadNext

      void loadNext() throws InterruptedException
      Loads one batch of identifiers and adds them to the sink, or calls PojoMassIdentifierSink.complete() to notify the caller that there are no more identifiers to load.

      Calls to the sink must be performed synchronously (before this method returns).

      InterruptedException - If the thread was interrupted while performing I/O operations. This will lead to aborting mass indexing completely.