java.lang.Object
org.elasticsearch.index.IndexingPressure
- All Implemented Interfaces:
IndexingPressureMonitor
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionclassclassNested classes/interfaces inherited from interface org.elasticsearch.index.IndexingPressureMonitor
IndexingPressureMonitor.IndexingPressureListener -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Setting<ByteSizeValue> static final Setting<ByteSizeValue> static final Setting<ByteSizeValue> static final Setting<ByteSizeValue> static final Setting<ByteSizeValue> static final Setting<ByteSizeValue> static final Setting<ByteSizeValue> static final Setting<ByteSizeValue> static final Setting<ByteSizeValue> static final Setting<ByteSizeValue> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidRegisters a listener to be notified of indexing pressure events.createCoordinatingOperation(boolean forceExecution) longReturns the maximum allowed size in bytes for any single indexing operation.markCoordinatingOperationStarted(int operations, long bytes, boolean forceExecution) markReplicaOperationStarted(int operations, long bytes, boolean forceExecution) startIncrementalCoordinating(int operations, long bytes, boolean forceExecution) stats()trackPrimaryOperationExpansion(int operations, long expandedBytes, boolean forceExecution) trackReplicaOperationExpansion(long expandedBytes, boolean forceExecution) validateAndMarkPrimaryOperationLocalToCoordinatingNodeStarted(int operations, long bytes, long largestOperationSizeInBytes, boolean allowsOperationsBeyondSizeLimit) validateAndMarkPrimaryOperationStarted(int operations, long bytes, long largestOperationSizeInBytes, boolean forceExecution, boolean allowsOperationsBeyondSizeLimit)
-
Field Details
-
MAX_INDEXING_BYTES
-
SPLIT_BULK_THRESHOLD
-
MAX_COORDINATING_BYTES
-
MAX_PRIMARY_BYTES
-
MAX_REPLICA_BYTES
-
SPLIT_BULK_HIGH_WATERMARK
-
SPLIT_BULK_HIGH_WATERMARK_SIZE
-
SPLIT_BULK_LOW_WATERMARK
-
SPLIT_BULK_LOW_WATERMARK_SIZE
-
MAX_OPERATION_SIZE
-
-
Constructor Details
-
IndexingPressure
-
-
Method Details
-
startIncrementalCoordinating
public IndexingPressure.Incremental startIncrementalCoordinating(int operations, long bytes, boolean forceExecution) -
markCoordinatingOperationStarted
public IndexingPressure.Coordinating markCoordinatingOperationStarted(int operations, long bytes, boolean forceExecution) -
createCoordinatingOperation
-
validateAndMarkPrimaryOperationLocalToCoordinatingNodeStarted
public Releasable validateAndMarkPrimaryOperationLocalToCoordinatingNodeStarted(int operations, long bytes, long largestOperationSizeInBytes, boolean allowsOperationsBeyondSizeLimit) -
validateAndMarkPrimaryOperationStarted
public Releasable validateAndMarkPrimaryOperationStarted(int operations, long bytes, long largestOperationSizeInBytes, boolean forceExecution, boolean allowsOperationsBeyondSizeLimit) -
trackPrimaryOperationExpansion
public Releasable trackPrimaryOperationExpansion(int operations, long expandedBytes, boolean forceExecution) -
trackReplicaOperationExpansion
-
markReplicaOperationStarted
-
stats
-
getMaxAllowedOperationSizeInBytes
public long getMaxAllowedOperationSizeInBytes()Description copied from interface:IndexingPressureMonitorReturns the maximum allowed size in bytes for any single indexing operation. Operations exceeding this limit may be rejected.- Specified by:
getMaxAllowedOperationSizeInBytesin interfaceIndexingPressureMonitor- Returns:
- the maximum allowed operation size in bytes
-
addListener
Description copied from interface:IndexingPressureMonitorRegisters a listener to be notified of indexing pressure events. The listener will receive callbacks when operations are tracked or rejected.- Specified by:
addListenerin interfaceIndexingPressureMonitor- Parameters:
listener- the listener to register for indexing pressure events
-