org.apache.lucene.index
Class TrackingConcurrentMergeScheduler

java.lang.Object
  org.apache.lucene.index.MergeScheduler
      org.apache.lucene.index.ConcurrentMergeScheduler
          org.apache.lucene.index.TrackingConcurrentMergeScheduler

Direct Known Subclasses:

ConcurrentMergeSchedulerProvider.CustomConcurrentMergeScheduler

public class TrackingConcurrentMergeScheduler
extends org.apache.lucene.index.ConcurrentMergeScheduler

An extension to the ConcurrentMergeScheduler that provides tracking on merge times, total and current merges.

Nested Class Summary

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

org.apache.lucene.index.ConcurrentMergeScheduler.MergeThread

Field Summary

protected ESLogger

logger

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

compareByMergeDocCount, dir, mergeThreadCount, mergeThreads, writer

Constructor Summary

TrackingConcurrentMergeScheduler(ESLogger logger)

Method Summary

long	currentMerges()
long	currentMergesNumDocs()
long	currentMergesSizeInBytes()
protected void	doMerge(org.apache.lucene.index.MergePolicy.OneMerge merge)
long	totalMergeNumDocs()
long	totalMerges()
long	totalMergeSizeInBytes()
long	totalMergeTime()

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

anyUnhandledExceptions, clearUnhandledExceptions, close, getMaxMergeCount, getMaxThreadCount, getMergeThread, getMergeThreadPriority, handleMergeException, 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

Field Detail

logger

protected final ESLogger logger

Constructor Detail

TrackingConcurrentMergeScheduler

public TrackingConcurrentMergeScheduler(ESLogger logger)

Method Detail

totalMerges

public long totalMerges()

totalMergeTime

public long totalMergeTime()

totalMergeNumDocs

public long totalMergeNumDocs()

totalMergeSizeInBytes

public long totalMergeSizeInBytes()

currentMerges

public long currentMerges()

currentMergesNumDocs

public long currentMergesNumDocs()

currentMergesSizeInBytes

public long currentMergesSizeInBytes()

doMerge

protected void doMerge(org.apache.lucene.index.MergePolicy.OneMerge merge)
                throws IOException

Overrides:

doMerge in class org.apache.lucene.index.ConcurrentMergeScheduler

Throws:

IOException