org.hibernate.search.batchindexing.impl
Class EntityConsumerLuceneWorkProducer

java.lang.Object
  org.hibernate.search.batchindexing.impl.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.

Author:

Sanne Grinovero

Constructor Summary

EntityConsumerLuceneWorkProducer(ProducerConsumerQueue<List<?>> entitySource, MassIndexerProgressMonitor monitor, SessionFactory sessionFactory, CountDownLatch producerEndSignal, SearchFactoryImplementor searchFactory, CacheMode cacheMode, BatchBackend backend, ErrorHandler errorHandler)

Method Summary

void	run(Session upperSession)

Methods inherited from class java.lang.Object

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

Constructor Detail

EntityConsumerLuceneWorkProducer

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

Method Detail

run

public void run(Session upperSession)

Specified by:

run in interface SessionAwareRunnable