Module org.elasticsearch.server
Package org.elasticsearch.index.engine
Class ElasticsearchConcurrentMergeScheduler
java.lang.Object
org.apache.lucene.index.MergeScheduler
org.apache.lucene.index.ConcurrentMergeScheduler
org.elasticsearch.index.engine.ElasticsearchConcurrentMergeScheduler
- All Implemented Interfaces:
Closeable,AutoCloseable,ElasticsearchMergeScheduler
public class ElasticsearchConcurrentMergeScheduler
extends org.apache.lucene.index.ConcurrentMergeScheduler
implements ElasticsearchMergeScheduler
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.MergeThreadNested classes/interfaces inherited from class org.apache.lucene.index.MergeScheduler
org.apache.lucene.index.MergeScheduler.MergeSource -
Field Summary
FieldsFields inherited from class org.apache.lucene.index.ConcurrentMergeScheduler
AUTO_DETECT_MERGES_AND_THREADS, DEFAULT_CPU_CORE_COUNT_PROPERTY, intraMergeExecutor, mergeThreadCount, mergeThreads, targetMBPerSecFields inherited from class org.apache.lucene.index.MergeScheduler
infoStream -
Method Summary
Modifier and TypeMethodDescriptionprotected voidafterMerge(OnGoingMerge merge) A callback allowing for custom logic before an actual merge starts.protected voidbeforeMerge(OnGoingMerge merge) A callback allowing for custom logic before an actual merge starts.org.apache.lucene.index.MergeSchedulerclone()voidclose()protected voiddoMerge(org.apache.lucene.index.MergeScheduler.MergeSource mergeSource, org.apache.lucene.index.MergePolicy.OneMerge merge) getIntraMergeExecutor(org.apache.lucene.index.MergePolicy.OneMerge merge) org.apache.lucene.index.MergeSchedulerprotected org.apache.lucene.index.ConcurrentMergeScheduler.MergeThreadgetMergeThread(org.apache.lucene.index.MergeScheduler.MergeSource mergeSource, org.apache.lucene.index.MergePolicy.OneMerge merge) protected booleanmaybeStall(org.apache.lucene.index.MergeScheduler.MergeSource mergeSource) protected voidvoidstats()protected booleanverbose()Methods inherited from class org.apache.lucene.index.ConcurrentMergeScheduler
disableAutoIOThrottle, doStall, enableAutoIOThrottle, getAutoIOThrottle, getForceMergeMBPerSec, getIORateLimitMBPerSec, getMaxMergeCount, getMaxThreadCount, handleMergeException, merge, mergeThreadCount, setDefaultMaxMergesAndThreads, setForceMergeMBPerSec, setMaxMergesAndThreads, sync, targetMBPerSecChanged, toString, updateMergeThreads, wrapForMerge
-
Field Details
-
logger
protected final org.apache.logging.log4j.Logger logger
-
-
Method Details
-
onGoingMerges
- Specified by:
onGoingMergesin interfaceElasticsearchMergeScheduler
-
getIntraMergeExecutor
- Overrides:
getIntraMergeExecutorin classorg.apache.lucene.index.ConcurrentMergeScheduler
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Overrides:
closein classorg.apache.lucene.index.ConcurrentMergeScheduler- Throws:
IOException
-
verbose
protected boolean verbose()- Overrides:
verbosein classorg.apache.lucene.index.MergeScheduler
-
message
- Overrides:
messagein classorg.apache.lucene.index.MergeScheduler
-
doMerge
protected void doMerge(org.apache.lucene.index.MergeScheduler.MergeSource mergeSource, org.apache.lucene.index.MergePolicy.OneMerge merge) throws IOException - Overrides:
doMergein classorg.apache.lucene.index.ConcurrentMergeScheduler- Throws:
IOException
-
beforeMerge
A callback allowing for custom logic before an actual merge starts. -
afterMerge
A callback allowing for custom logic before an actual merge starts. -
clone
public org.apache.lucene.index.MergeScheduler clone() -
maybeStall
protected boolean maybeStall(org.apache.lucene.index.MergeScheduler.MergeSource mergeSource) - Overrides:
maybeStallin classorg.apache.lucene.index.ConcurrentMergeScheduler
-
getMergeThread
protected org.apache.lucene.index.ConcurrentMergeScheduler.MergeThread getMergeThread(org.apache.lucene.index.MergeScheduler.MergeSource mergeSource, org.apache.lucene.index.MergePolicy.OneMerge merge) throws IOException - Overrides:
getMergeThreadin classorg.apache.lucene.index.ConcurrentMergeScheduler- Throws:
IOException
-
stats
- Specified by:
statsin interfaceElasticsearchMergeScheduler
-
refreshConfig
public void refreshConfig()- Specified by:
refreshConfigin interfaceElasticsearchMergeScheduler
-
getMergeScheduler
public org.apache.lucene.index.MergeScheduler getMergeScheduler()- Specified by:
getMergeSchedulerin interfaceElasticsearchMergeScheduler
-