Package org.hibernate.search.mapper.orm.loading.impl

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, HibernateOrmMassLoadingContext options, PojoMassIdentifierSink<I> sink, SharedSessionContractImplementor session)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this PojoMassIdentifierLoader.
void	loadNext()	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.
long	totalCount()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

HibernateOrmMassIdentifierLoader

public HibernateOrmMassIdentifierLoader(HibernateOrmQueryLoader<E,I> typeQueryLoader,
 HibernateOrmMassLoadingContext options,
 PojoMassIdentifierSink<I> sink,
 SharedSessionContractImplementor session)

Method Details

close

public void close()

Description copied from interface: PojoMassIdentifierLoader

Closes this PojoMassIdentifierLoader.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PojoMassIdentifierLoader

totalCount

public long totalCount()

Specified by:

totalCount in interface PojoMassIdentifierLoader

Returns:

The total count of identifiers expected to be loaded.

loadNext

public void loadNext()
              throws InterruptedException

Description copied from interface: PojoMassIdentifierLoader

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).

Specified by:

loadNext in interface PojoMassIdentifierLoader

Throws:

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