org.hibernate.search.backend.impl.lucene.overrides
Class ConcurrentMergeScheduler

java.lang.Object
  org.apache.lucene.index.MergeScheduler
      org.apache.lucene.index.ConcurrentMergeScheduler
          org.hibernate.search.backend.impl.lucene.overrides.ConcurrentMergeScheduler

public class ConcurrentMergeScheduler
extends ConcurrentMergeScheduler

We customize Lucene's ConcurrentMergeScheduler to route eventual exceptions to our configurable errorhandler.

Since:

3.3

Author:

Sanne Grinovero

See Also:

ErrorHandler

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.lucene.index.ConcurrentMergeScheduler

ConcurrentMergeScheduler.MergeThread

Field Summary

Fields inherited from class org.apache.lucene.index.ConcurrentMergeScheduler

compareByMergeDocCount, dir, mergeThreadCount, mergeThreads, writer

Constructor Summary

ConcurrentMergeScheduler(ErrorHandler errorHandler, String indexName)

Method Summary

protected ConcurrentMergeScheduler.MergeThread	getMergeThread(IndexWriter writer, MergePolicy.OneMerge merge)
protected void	handleMergeException(Throwable t)

Methods inherited from class org.apache.lucene.index.ConcurrentMergeScheduler

anyUnhandledExceptions, clearUnhandledExceptions, close, doMerge, getMaxMergeCount, getMaxThreadCount, getMergeThreadPriority, merge, mergeThreadCount, message, setMaxMergeCount, setMaxThreadCount, setMergeThreadPriority, setTestMode, sync, updateMergeThreads, verbose

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentMergeScheduler

public ConcurrentMergeScheduler(ErrorHandler errorHandler,
                                String indexName)

Method Detail

handleMergeException

protected void handleMergeException(Throwable t)

Overrides:

handleMergeException in class ConcurrentMergeScheduler

getMergeThread

protected ConcurrentMergeScheduler.MergeThread getMergeThread(IndexWriter writer,
                                                              MergePolicy.OneMerge merge)
                                                       throws IOException

Overrides:

getMergeThread in class ConcurrentMergeScheduler

Throws:

IOException