Class HibernateOrmMassIdentifierLoader<E,I>
java.lang.Object
org.hibernate.search.mapper.orm.loading.impl.HibernateOrmMassIdentifierLoader<E,I>
- All Implemented Interfaces:
AutoCloseable,PojoMassIdentifierLoader
public final class HibernateOrmMassIdentifierLoader<E,I>
extends Object
implements PojoMassIdentifierLoader
-
Constructor Summary
ConstructorsConstructorDescriptionHibernateOrmMassIdentifierLoader(HibernateOrmQueryLoader<E, I> typeQueryLoader, HibernateOrmMassLoadingContext options, PojoMassIdentifierSink<I> sink, SharedSessionContractImplementor session) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()Closes thisPojoMassIdentifierLoader.voidloadNext()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
-
Constructor Details
-
Method Details
-
close
public void close()Description copied from interface:PojoMassIdentifierLoaderCloses thisPojoMassIdentifierLoader.- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfacePojoMassIdentifierLoader
-
totalCount
public long totalCount()- Specified by:
totalCountin interfacePojoMassIdentifierLoader- Returns:
- The total count of identifiers expected to be loaded.
-
loadNext
Description copied from interface:PojoMassIdentifierLoaderLoads 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).
- Specified by:
loadNextin interfacePojoMassIdentifierLoader- Throws:
InterruptedException- If the thread was interrupted while performing I/O operations. This will lead to aborting mass indexing completely.
-