Package org.elasticsearch.index

Class IndexingPressure

java.lang.Object

org.elasticsearch.index.IndexingPressure

public class IndexingPressure
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final Setting<ByteSizeValue>	MAX_INDEXING_BYTES

Constructor Summary

Constructors

Constructor	Description
IndexingPressure(Settings settings)

Method Summary

Modifier and Type	Method	Description
long	getCurrentCombinedCoordinatingAndPrimaryBytes()
long	getCurrentCoordinatingBytes()
long	getCurrentPrimaryBytes()
long	getCurrentReplicaBytes()
Releasable	markCoordinatingOperationStarted(long bytes, boolean forceExecution)
Releasable	markPrimaryOperationLocalToCoordinatingNodeStarted(long bytes)
Releasable	markPrimaryOperationStarted(long bytes, boolean forceExecution)
Releasable	markReplicaOperationStarted(long bytes, boolean forceExecution)
IndexingPressureStats	stats()

Methods inherited from class java.lang.Object

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

Field Details

MAX_INDEXING_BYTES

public static final Setting<ByteSizeValue> MAX_INDEXING_BYTES

Constructor Details

IndexingPressure

public IndexingPressure(Settings settings)

Method Details

markCoordinatingOperationStarted

public Releasable markCoordinatingOperationStarted(long bytes,
 boolean forceExecution)

markPrimaryOperationLocalToCoordinatingNodeStarted

public Releasable markPrimaryOperationLocalToCoordinatingNodeStarted(long bytes)

markPrimaryOperationStarted

public Releasable markPrimaryOperationStarted(long bytes,
 boolean forceExecution)

markReplicaOperationStarted

public Releasable markReplicaOperationStarted(long bytes,
 boolean forceExecution)

getCurrentCombinedCoordinatingAndPrimaryBytes

public long getCurrentCombinedCoordinatingAndPrimaryBytes()

getCurrentCoordinatingBytes

public long getCurrentCoordinatingBytes()

getCurrentPrimaryBytes

public long getCurrentPrimaryBytes()

getCurrentReplicaBytes

public long getCurrentReplicaBytes()

stats

public IndexingPressureStats stats()