Package org.elasticsearch.index
Class IndexingPressure
java.lang.Object
org.elasticsearch.index.IndexingPressure
public class IndexingPressure
extends java.lang.Object
-
Field Summary
Fields Modifier and Type Field Description static 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()
org.elasticsearch.common.lease.Releasable
markCoordinatingOperationStarted(long bytes, boolean forceExecution)
org.elasticsearch.common.lease.Releasable
markPrimaryOperationLocalToCoordinatingNodeStarted(long bytes)
org.elasticsearch.common.lease.Releasable
markPrimaryOperationStarted(long bytes, boolean forceExecution)
org.elasticsearch.common.lease.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
-
-
Constructor Details
-
IndexingPressure
-
-
Method Details
-
markCoordinatingOperationStarted
public org.elasticsearch.common.lease.Releasable markCoordinatingOperationStarted(long bytes, boolean forceExecution) -
markPrimaryOperationLocalToCoordinatingNodeStarted
public org.elasticsearch.common.lease.Releasable markPrimaryOperationLocalToCoordinatingNodeStarted(long bytes) -
markPrimaryOperationStarted
public org.elasticsearch.common.lease.Releasable markPrimaryOperationStarted(long bytes, boolean forceExecution) -
markReplicaOperationStarted
public org.elasticsearch.common.lease.Releasable markReplicaOperationStarted(long bytes, boolean forceExecution) -
getCurrentCombinedCoordinatingAndPrimaryBytes
public long getCurrentCombinedCoordinatingAndPrimaryBytes() -
getCurrentCoordinatingBytes
public long getCurrentCoordinatingBytes() -
getCurrentPrimaryBytes
public long getCurrentPrimaryBytes() -
getCurrentReplicaBytes
public long getCurrentReplicaBytes() -
stats
-