public abstract class MergeSchedulerProvider extends AbstractIndexShardComponent implements Closeable
Modifier and Type | Class and Description |
---|---|
static interface |
MergeSchedulerProvider.FailureListener |
static interface |
MergeSchedulerProvider.Listener
Listener for events before/after single merges.
|
Modifier and Type | Field and Description |
---|---|
static String |
FORCE_ASYNC_MERGE |
componentSettings, indexSettings, logger, shardId
Modifier | Constructor and Description |
---|---|
protected |
MergeSchedulerProvider(ShardId shardId,
Settings indexSettings,
ThreadPool threadPool) |
Modifier and Type | Method and Description |
---|---|
void |
addFailureListener(MergeSchedulerProvider.FailureListener listener) |
void |
addListener(MergeSchedulerProvider.Listener listener) |
protected void |
afterMerge(OnGoingMerge merge) |
protected void |
beforeMerge(OnGoingMerge merge) |
protected abstract org.apache.lucene.index.MergeScheduler |
buildMergeScheduler() |
abstract void |
close() |
protected void |
failedMerge(org.apache.lucene.index.MergePolicy.MergeException e) |
abstract int |
getMaxMerges()
Maximum number of allowed running merges before index throttling kicks in.
|
org.apache.lucene.index.MergeScheduler |
newMergeScheduler() |
abstract Set<OnGoingMerge> |
onGoingMerges() |
void |
removeFailureListener(MergeSchedulerProvider.FailureListener listener) |
void |
removeListener(MergeSchedulerProvider.Listener listener) |
abstract MergeStats |
stats() |
indexSettings, nodeName, shardId
public static final String FORCE_ASYNC_MERGE
protected MergeSchedulerProvider(ShardId shardId, @IndexSettings Settings indexSettings, ThreadPool threadPool)
public void addFailureListener(MergeSchedulerProvider.FailureListener listener)
public void removeFailureListener(MergeSchedulerProvider.FailureListener listener)
public void addListener(MergeSchedulerProvider.Listener listener)
public void removeListener(MergeSchedulerProvider.Listener listener)
protected void failedMerge(org.apache.lucene.index.MergePolicy.MergeException e)
protected void beforeMerge(OnGoingMerge merge)
protected void afterMerge(OnGoingMerge merge)
public final org.apache.lucene.index.MergeScheduler newMergeScheduler()
public abstract int getMaxMerges()
protected abstract org.apache.lucene.index.MergeScheduler buildMergeScheduler()
public abstract MergeStats stats()
public abstract Set<OnGoingMerge> onGoingMerges()
public abstract void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2009–2015. All rights reserved.