public class ConcurrentMergeSchedulerProvider extends MergeSchedulerProvider
Modifier and Type | Class and Description |
---|---|
static class |
ConcurrentMergeSchedulerProvider.CustomConcurrentMergeScheduler |
MergeSchedulerProvider.FailureListener, MergeSchedulerProvider.Listener
Modifier and Type | Field and Description |
---|---|
static String |
MAX_MERGE_COUNT |
static String |
MAX_THREAD_COUNT |
FORCE_ASYNC_MERGE
componentSettings, indexSettings, logger, shardId
Constructor and Description |
---|
ConcurrentMergeSchedulerProvider(ShardId shardId,
Settings indexSettings,
ThreadPool threadPool,
IndexSettingsService indexSettingsService) |
Modifier and Type | Method and Description |
---|---|
org.apache.lucene.index.MergeScheduler |
buildMergeScheduler() |
void |
close() |
int |
getMaxMerges()
Maximum number of allowed running merges before index throttling kicks in.
|
Set<OnGoingMerge> |
onGoingMerges() |
MergeStats |
stats() |
addFailureListener, addListener, afterMerge, beforeMerge, failedMerge, newMergeScheduler, removeFailureListener, removeListener
indexSettings, nodeName, shardId
public static final String MAX_THREAD_COUNT
public static final String MAX_MERGE_COUNT
@Inject public ConcurrentMergeSchedulerProvider(ShardId shardId, @IndexSettings Settings indexSettings, ThreadPool threadPool, IndexSettingsService indexSettingsService)
public org.apache.lucene.index.MergeScheduler buildMergeScheduler()
buildMergeScheduler
in class MergeSchedulerProvider
public MergeStats stats()
stats
in class MergeSchedulerProvider
public Set<OnGoingMerge> onGoingMerges()
onGoingMerges
in class MergeSchedulerProvider
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class MergeSchedulerProvider
public int getMaxMerges()
MergeSchedulerProvider
getMaxMerges
in class MergeSchedulerProvider
Copyright © 2009–2015. All rights reserved.