Package org.hibernate.search.batchindexing

Class EntityConsumerLuceneWorkProducer

java.lang.Object

org.hibernate.search.batchindexing.EntityConsumerLuceneWorkProducer

All Implemented Interfaces:

SessionAwareRunnable

public class EntityConsumerLuceneWorkProducer
extends Object
implements SessionAwareRunnable

Component of batch-indexing pipeline, using chained producer-consumers. This Runnable will consume entities taken one-by-one from the queue and produce for each entity an AddLuceneWork to the output queue.

Constructor Summary

Constructors

Constructor	Description
EntityConsumerLuceneWorkProducer(ProducerConsumerQueue<List<?>> entitySource, MassIndexerProgressMonitor monitor, org.hibernate.SessionFactory sessionFactory, CountDownLatch producerEndSignal, SearchFactoryImplementor searchFactory, org.hibernate.CacheMode cacheMode, BatchBackend backend)

Method Summary

Modifier and Type	Method	Description
void	run(org.hibernate.Session upperSession)

Methods inherited from class java.lang.Object

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

Constructor Details

EntityConsumerLuceneWorkProducer

public EntityConsumerLuceneWorkProducer(ProducerConsumerQueue<List<?>> entitySource,
 MassIndexerProgressMonitor monitor,
 org.hibernate.SessionFactory sessionFactory,
 CountDownLatch producerEndSignal,
 SearchFactoryImplementor searchFactory,
 org.hibernate.CacheMode cacheMode,
 BatchBackend backend)

Method Details

run

public void run(org.hibernate.Session upperSession)

Specified by:

run in interface SessionAwareRunnable