Class DownsampleShardTask

All Implemented Interfaces:
Traceable

public class DownsampleShardTask extends AllocatedPersistentTask
  • Field Details

  • Constructor Details

  • Method Details

    • init

      protected void init(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId)
      Overrides:
      init in class AllocatedPersistentTask
    • testInit

      public void testInit(PersistentTasksService persistentTasksService, TaskManager taskManager, String persistentTaskId, long allocationId)
    • getDownsampleIndex

      public String getDownsampleIndex()
    • config

      public DownsampleConfig config()
    • shardId

      public ShardId shardId()
    • getTotalShardDocCount

      public long getTotalShardDocCount()
    • getStatus

      public Task.Status getStatus()
      Overrides:
      getStatus in class AllocatedPersistentTask
    • 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

      public DownsampleBeforeBulkInfo getLastBeforeBulkInfo()
    • getLastAfterBulkInfo

      public DownsampleAfterBulkInfo getLastAfterBulkInfo()
    • getDocsProcessed

      public long getDocsProcessed()
    • getRollupStartTime

      public long getRollupStartTime()
    • getDownsampleShardIndexerStatus

      public DownsampleShardIndexerStatus 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

      public void setBeforeBulkInfo(DownsampleBeforeBulkInfo beforeBulkInfo)
    • setAfterBulkInfo

      public void setAfterBulkInfo(DownsampleAfterBulkInfo afterBulkInfo)
    • setDownsampleShardIndexerStatus

      public void setDownsampleShardIndexerStatus(DownsampleShardIndexerStatus status)
    • setTotalShardDocCount

      public void setTotalShardDocCount(int totalShardDocCount)
    • setDocsProcessed

      public void setDocsProcessed(long docsProcessed)
    • updateBulkInfo

      public void updateBulkInfo(long bulkIngestTookMillis, long bulkTookMillis)
    • getDownsampleBulkInfo

      public DownsampleBulkInfo getDownsampleBulkInfo()