Package com.linkedin.venice.hadoop.task

Interface TaskTracker

All Known Subinterfaces:
DataWriterTaskTracker
All Known Implementing Classes:
CounterBackedMapReduceDataWriterTaskTracker, ReporterBackedMapReduceDataWriterTaskTracker, SparkDataWriterTaskTracker
public interface TaskTracker
An interface to report task health and track task progress for different execution engines

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final float
    PROGRESS_COMPLETED
     
    static final float
    PROGRESS_NOT_SUPPORTED
     

  • Method Summary

    Modifier and Type
    Method
    Description
    default float
    getProgress()
    Get the progress of the task.
    default void
    heartbeat()
    Report task heartbeat if the execution engine requires it

  • Field Details

  • Method Details

    • heartbeat

      default void heartbeat()
      Report task heartbeat if the execution engine requires it

    • getProgress

      default float getProgress()
      Get the progress of the task. If the engine supports fetching the progress, progress is represented as a number between 0 and 1 (inclusive). If the engine doesn't support fetching the progress, a value of -1 is returned.