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
Constructors Constructor Description HibernateOrmMassIdentifierLoader(HibernateOrmQueryLoader<E,I> typeQueryLoader, HibernateOrmMassLoadingOptions options, PojoMassIdentifierSink<I> sink, org.hibernate.engine.spi.SharedSessionContractImplementor session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()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.longtotalCount()
-
-
-
Constructor Detail
-
HibernateOrmMassIdentifierLoader
public HibernateOrmMassIdentifierLoader(HibernateOrmQueryLoader<E,I> typeQueryLoader, HibernateOrmMassLoadingOptions options, PojoMassIdentifierSink<I> sink, org.hibernate.engine.spi.SharedSessionContractImplementor session)
-
-
Method Detail
-
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
public void loadNext() throws InterruptedExceptionDescription 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.
-
-