org.elasticsearch.index.merge.scheduler

Class ConcurrentMergeSchedulerProvider.CustomConcurrentMergeScheduler

java.lang.Object

org.apache.lucene.index.MergeScheduler

org.apache.lucene.index.ConcurrentMergeScheduler

org.apache.lucene.index.TrackingConcurrentMergeScheduler

org.elasticsearch.index.merge.scheduler.ConcurrentMergeSchedulerProvider.CustomConcurrentMergeScheduler

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

ConcurrentMergeSchedulerProvider

public static class ConcurrentMergeSchedulerProvider.CustomConcurrentMergeScheduler
extends TrackingConcurrentMergeScheduler

Nested Class Summary

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

org.apache.lucene.index.ConcurrentMergeScheduler.MergeThread

Field Summary

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

logger

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

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

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.
void	close()
protected org.apache.lucene.index.ConcurrentMergeScheduler.MergeThread	getMergeThread(org.apache.lucene.index.IndexWriter writer, org.apache.lucene.index.MergePolicy.OneMerge merge)
protected void	handleMergeException(Throwable exc)

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

clone, currentMerges, currentMergesNumDocs, currentMergesSizeInBytes, doMerge, onGoingMerges, totalMergeNumDocs, totalMerges, totalMergeSizeInBytes, totalMergeTime

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

getMaxMergeCount, getMaxThreadCount, getMergeThreadPriority, 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

Method Detail

getMergeThread

protected org.apache.lucene.index.ConcurrentMergeScheduler.MergeThread getMergeThread(org.apache.lucene.index.IndexWriter writer,
                                                                                      org.apache.lucene.index.MergePolicy.OneMerge merge)
                                                                               throws IOException

Overrides:

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

Throws:

IOException

handleMergeException

protected void handleMergeException(Throwable exc)

Overrides:

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

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

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

beforeMerge

protected void beforeMerge(OnGoingMerge merge)

Description copied from class: TrackingConcurrentMergeScheduler

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

Overrides:

beforeMerge in class TrackingConcurrentMergeScheduler

afterMerge

protected void afterMerge(OnGoingMerge merge)

Description copied from class: TrackingConcurrentMergeScheduler

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

Overrides:

afterMerge in class TrackingConcurrentMergeScheduler