Module org.elasticsearch.xcore
Class DownsampleShardTask
java.lang.Object
org.elasticsearch.tasks.Task
org.elasticsearch.tasks.CancellableTask
org.elasticsearch.persistent.AllocatedPersistentTask
org.elasticsearch.xpack.core.downsample.DownsampleShardTask
- All Implemented Interfaces:
Traceable
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.persistent.AllocatedPersistentTask
AllocatedPersistentTask.StateNested classes/interfaces inherited from class org.elasticsearch.tasks.CancellableTask
CancellableTask.CancellationListenerNested classes/interfaces inherited from class org.elasticsearch.tasks.Task
Task.Status -
Field Summary
FieldsFields inherited from class org.elasticsearch.tasks.Task
APM_TRACE_CONTEXT, HEADERS_TO_COPY, PARENT_APM_TRACE_CONTEXT, PARENT_TRACE_PARENT_HEADER, PARENT_TRACE_STATE, TRACE_ID, TRACE_PARENT_HTTP_HEADER, TRACE_START_TIME, TRACE_STATE, X_ELASTIC_PRODUCT_ORIGIN_HTTP_HEADER, X_ELASTIC_PROJECT_ID_HTTP_HEADER, X_OPAQUE_ID_HTTP_HEADER -
Constructor Summary
ConstructorsConstructorDescriptionDownsampleShardTask(long id, String type, String action, TaskId parentTask, String downsampleIndex, long indexStartTimeMillis, long indexEndTimeMillis, DownsampleConfig config, Map<String, String> headers, ShardId shardId) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddNumFailed(long count) voidaddNumIndexed(long count) voidaddNumReceived(long count) voidaddNumSent(long count) config()longfloatlonglonglonglonglonglonglonglonglonglonglongprotected voidinit(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId) voidsetAfterBulkInfo(DownsampleAfterBulkInfo afterBulkInfo) voidsetBeforeBulkInfo(DownsampleBeforeBulkInfo beforeBulkInfo) voidsetDocsProcessed(long docsProcessed) voidvoidsetLastIndexingTimestamp(long timestamp) voidsetLastSourceTimestamp(long timestamp) voidsetLastTargetTimestamp(long timestamp) voidsetTotalShardDocCount(int totalShardDocCount) shardId()voidtestInit(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId) voidupdateBulkInfo(long bulkIngestTookMillis, long bulkTookMillis) Methods inherited from class org.elasticsearch.persistent.AllocatedPersistentTask
getAllocationId, getFailure, getPersistentTaskId, isCompleted, markAsCancelled, markAsCompleted, markAsFailed, markAsLocallyAborted, updatePersistentTaskState, updateProjectPersistentTaskState, waitForPersistentTaskMethods inherited from class org.elasticsearch.tasks.CancellableTask
addListener, ensureNotCancelled, getReasonCancelled, isCancelled, notifyIfCancelled, onCancelled, shouldCancelChildrenOnCancellation, toStringMethods inherited from class org.elasticsearch.tasks.Task
getAction, getDescription, getHeader, getId, getParentTaskId, getProjectId, getSpanId, getStartTime, getStartTimeNanos, getType, headers, result, result, taskInfo, taskInfo
-
Field Details
-
TASK_NAME
- See Also:
-
-
Constructor Details
-
DownsampleShardTask
-
-
Method Details
-
init
protected void init(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId) - Overrides:
initin classAllocatedPersistentTask
-
testInit
public void testInit(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId) -
getDownsampleIndex
-
config
-
shardId
-
getTotalShardDocCount
public long getTotalShardDocCount() -
getStatus
- Overrides:
getStatusin classAllocatedPersistentTask
-
getNumReceived
public long getNumReceived() -
getNumSent
public long getNumSent() -
getNumIndexed
public long getNumIndexed() -
getNumFailed
public long getNumFailed() -
getLastSourceTimestamp
public long getLastSourceTimestamp() -
getLastTargetTimestamp
public long getLastTargetTimestamp() -
getLastBeforeBulkInfo
-
getLastAfterBulkInfo
-
getDocsProcessed
public long getDocsProcessed() -
getRollupStartTime
public long getRollupStartTime() -
getDownsampleShardIndexerStatus
-
getLastIndexingTimestamp
public long getLastIndexingTimestamp() -
getIndexStartTimeMillis
public long getIndexStartTimeMillis() -
getIndexEndTimeMillis
public long getIndexEndTimeMillis() -
getDocsProcessedPercentage
public float getDocsProcessedPercentage() -
addNumReceived
public void addNumReceived(long count) -
addNumSent
public void addNumSent(long count) -
addNumIndexed
public void addNumIndexed(long count) -
addNumFailed
public void addNumFailed(long count) -
setLastSourceTimestamp
public void setLastSourceTimestamp(long timestamp) -
setLastTargetTimestamp
public void setLastTargetTimestamp(long timestamp) -
setLastIndexingTimestamp
public void setLastIndexingTimestamp(long timestamp) -
setBeforeBulkInfo
-
setAfterBulkInfo
-
setDownsampleShardIndexerStatus
-
setTotalShardDocCount
public void setTotalShardDocCount(int totalShardDocCount) -
setDocsProcessed
public void setDocsProcessed(long docsProcessed) -
updateBulkInfo
public void updateBulkInfo(long bulkIngestTookMillis, long bulkTookMillis) -
getDownsampleBulkInfo
-