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
org.elasticsearch.core.Releasable	markCoordinatingOperationStarted(int operations, long bytes, boolean forceExecution)
org.elasticsearch.core.Releasable	markPrimaryOperationLocalToCoordinatingNodeStarted(int operations, long bytes)
org.elasticsearch.core.Releasable	markPrimaryOperationStarted(int operations, long bytes, boolean forceExecution)
org.elasticsearch.core.Releasable	markReplicaOperationStarted(int operations, 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 org.elasticsearch.core.Releasable markCoordinatingOperationStarted(int operations,
 long bytes,
 boolean forceExecution)

markPrimaryOperationLocalToCoordinatingNodeStarted

public org.elasticsearch.core.Releasable markPrimaryOperationLocalToCoordinatingNodeStarted(int operations,
 long bytes)

markPrimaryOperationStarted

public org.elasticsearch.core.Releasable markPrimaryOperationStarted(int operations,
 long bytes,
 boolean forceExecution)

markReplicaOperationStarted

public org.elasticsearch.core.Releasable markReplicaOperationStarted(int operations,
 long bytes,
 boolean forceExecution)

stats

public IndexingPressureStats stats()