org.elasticsearch.index.merge.scheduler

Class ConcurrentMergeSchedulerProvider

java.lang.Object

org.elasticsearch.index.shard.AbstractIndexShardComponent

org.elasticsearch.index.merge.scheduler.MergeSchedulerProvider

org.elasticsearch.index.merge.scheduler.ConcurrentMergeSchedulerProvider

All Implemented Interfaces:

Closeable, AutoCloseable, IndexShardComponent

public class ConcurrentMergeSchedulerProvider
extends MergeSchedulerProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ConcurrentMergeSchedulerProvider.CustomConcurrentMergeScheduler

Nested classes/interfaces inherited from class org.elasticsearch.index.merge.scheduler.MergeSchedulerProvider

MergeSchedulerProvider.FailureListener, MergeSchedulerProvider.Listener

Field Summary

Fields

Modifier and Type	Field and Description
static String	MAX_MERGE_COUNT
static String	MAX_THREAD_COUNT

Fields inherited from class org.elasticsearch.index.merge.scheduler.MergeSchedulerProvider

FORCE_ASYNC_MERGE

Fields inherited from class org.elasticsearch.index.shard.AbstractIndexShardComponent

componentSettings, indexSettings, logger, shardId

Constructor Summary

Constructors

Constructor and Description
ConcurrentMergeSchedulerProvider(ShardId shardId, Settings indexSettings, ThreadPool threadPool, IndexSettingsService indexSettingsService)

Method Summary

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()

Methods inherited from class org.elasticsearch.index.merge.scheduler.MergeSchedulerProvider

addFailureListener, addListener, afterMerge, beforeMerge, failedMerge, newMergeScheduler, removeFailureListener, removeListener

Methods inherited from class org.elasticsearch.index.shard.AbstractIndexShardComponent

indexSettings, nodeName, shardId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_THREAD_COUNT

public static final String MAX_THREAD_COUNT

See Also:

Constant Field Values

MAX_MERGE_COUNT

public static final String MAX_MERGE_COUNT

See Also:

Constant Field Values

Constructor Detail

ConcurrentMergeSchedulerProvider

@Inject
public ConcurrentMergeSchedulerProvider(ShardId shardId,
                                                @IndexSettings
                                                Settings indexSettings,
                                                ThreadPool threadPool,
                                                IndexSettingsService indexSettingsService)

Method Detail

buildMergeScheduler

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

Specified by:

buildMergeScheduler in class MergeSchedulerProvider

stats

public MergeStats stats()

Specified by:

stats in class MergeSchedulerProvider

onGoingMerges

public Set<OnGoingMerge> onGoingMerges()

Specified by:

onGoingMerges in class MergeSchedulerProvider

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class MergeSchedulerProvider

getMaxMerges

public int getMaxMerges()

Description copied from class: MergeSchedulerProvider

Maximum number of allowed running merges before index throttling kicks in.

Specified by:

getMaxMerges in class MergeSchedulerProvider