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

Class HibernateOrmMassEntityLoader<E,I>

java.lang.Object

org.hibernate.search.mapper.orm.loading.impl.HibernateOrmMassEntityLoader<E,I>

All Implemented Interfaces:

AutoCloseable, PojoMassEntityLoader<I>

public final class HibernateOrmMassEntityLoader<E,I>
extends Object
implements PojoMassEntityLoader<I>

Constructor Summary

Constructors

Constructor	Description
HibernateOrmMassEntityLoader(HibernateOrmQueryLoader<E,?> typeGroupLoader, HibernateOrmMassLoadingOptions options, PojoMassEntitySink<E> sink, org.hibernate.engine.spi.SessionImplementor session)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this PojoMassEntityLoader.
void	load(List<I> identifiers)	Loads the entities corresponding to the given identifiers and adds them to the given sink, blocking the current thread while doing so.

Methods inherited from class java.lang.Object

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

Constructor Detail

HibernateOrmMassEntityLoader

public HibernateOrmMassEntityLoader(HibernateOrmQueryLoader<E,?> typeGroupLoader,
                                    HibernateOrmMassLoadingOptions options,
                                    PojoMassEntitySink<E> sink,
                                    org.hibernate.engine.spi.SessionImplementor session)

Method Detail

close

public void close()

Description copied from interface: PojoMassEntityLoader

Closes this PojoMassEntityLoader.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PojoMassEntityLoader<E>

load

public void load(List<I> identifiers)
          throws InterruptedException

Description copied from interface: PojoMassEntityLoader

Loads the entities corresponding to the given identifiers and adds them to the given sink, blocking the current thread while doing so.

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

Entities must be passed to the sink using a single call to PojoMassEntitySink.accept(List).

Entities passed to the sink do not need to be the same order as identifiers.

Specified by:

load in interface PojoMassEntityLoader<E>

Parameters:

identifiers - A list of identifiers of entities to load.

Throws:

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