Interface PojoMassIdentifierLoader
-
- All Superinterfaces:
AutoCloseable
public interface PojoMassIdentifierLoader extends AutoCloseable
A loader of entity identifiers in batch, used in particular for mass indexing.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close()
Closes thisPojoMassIdentifierLoader
.void
loadNext()
Loads one batch of identifiers and adds them to the sink, or callsPojoMassIdentifierSink.complete()
to notify the caller that there are no more identifiers to load.long
totalCount()
-
-
-
Method Detail
-
close
void close()
Closes thisPojoMassIdentifierLoader
.- Specified by:
close
in interfaceAutoCloseable
-
totalCount
long totalCount()
- Returns:
- 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 callsPojoMassIdentifierSink.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).
- Throws:
InterruptedException
- If the thread was interrupted while performing I/O operations. This will lead to aborting mass indexing completely.
-
-