org.apache.lucene.index
Class TrackingSerialMergeScheduler

java.lang.Object
  org.apache.lucene.index.MergeScheduler
      org.apache.lucene.index.TrackingSerialMergeScheduler

Direct Known Subclasses:

SerialMergeSchedulerProvider.CustomSerialMergeScheduler

public class TrackingSerialMergeScheduler
extends org.apache.lucene.index.MergeScheduler

Field Summary

protected ESLogger

logger

Constructor Summary

TrackingSerialMergeScheduler(ESLogger logger)

Method Summary

void	close()
long	currentMerges()
long	currentMergesNumDocs()
long	currentMergesSizeInBytes()
void	merge(org.apache.lucene.index.IndexWriter writer) Just do the merges in sequence.
long	totalMergeNumDocs()
long	totalMerges()
long	totalMergeSizeInBytes()
long	totalMergeTime()

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

TrackingSerialMergeScheduler

public TrackingSerialMergeScheduler(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()

merge

public void merge(org.apache.lucene.index.IndexWriter writer)
           throws org.apache.lucene.index.CorruptIndexException,
                  IOException

Just do the merges in sequence. We do this "synchronized" so that even if the application is using multiple threads, only one merge may run at a time.

Specified by:

merge in class org.apache.lucene.index.MergeScheduler

Throws:

org.apache.lucene.index.CorruptIndexException

IOException

close

public void close()

Specified by:

close in class org.apache.lucene.index.MergeScheduler