org.apache.lucene.index

Class TrackingConcurrentMergeScheduler

java.lang.Object

org.apache.lucene.index.MergeScheduler

org.apache.lucene.index.ConcurrentMergeScheduler

org.apache.lucene.index.TrackingConcurrentMergeScheduler

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

ConcurrentMergeSchedulerProvider.CustomConcurrentMergeScheduler, SerialMergeSchedulerProvider.CustomSerialMergeScheduler

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

Fields

Modifier and Type	Field and Description
protected ESLogger	logger

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

compareByMergeDocCount, DEFAULT_MAX_MERGE_COUNT, DEFAULT_MAX_THREAD_COUNT, dir, mergeThreadCount, mergeThreads, writer

Constructor Summary

Constructors

Constructor and Description
TrackingConcurrentMergeScheduler(ESLogger logger)

Method Summary

Modifier and Type	Method and Description
protected void	afterMerge(OnGoingMerge merge) A callback allowing for custom logic before an actual merge starts.
protected void	beforeMerge(OnGoingMerge merge) A callback allowing for custom logic before an actual merge starts.
org.apache.lucene.index.MergeScheduler	clone()
long	currentMerges()
long	currentMergesNumDocs()
long	currentMergesSizeInBytes()
protected void	doMerge(org.apache.lucene.index.MergePolicy.OneMerge merge)
Set<OnGoingMerge>	onGoingMerges()
long	totalMergeNumDocs()
long	totalMerges()
long	totalMergeSizeInBytes()
long	totalMergeTime()

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

close, getMaxMergeCount, getMaxThreadCount, getMergeThread, getMergeThreadPriority, handleMergeException, merge, mergeThreadCount, message, setMaxMergesAndThreads, setMergeThreadPriority, sync, toString, updateMergeThreads, verbose

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, 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()

onGoingMerges

public Set<OnGoingMerge> onGoingMerges()

doMerge

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

Overrides:

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

Throws:

IOException

beforeMerge

protected void beforeMerge(OnGoingMerge merge)

A callback allowing for custom logic before an actual merge starts.

afterMerge

protected void afterMerge(OnGoingMerge merge)

A callback allowing for custom logic before an actual merge starts.

clone

public org.apache.lucene.index.MergeScheduler clone()

Overrides:

clone in class Object