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 float
PROGRESS_COMPLETED
static float
PROGRESS_NOT_SUPPORTED
-
Method Summary
All Methods Instance Methods Default Methods 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 Detail
-
PROGRESS_NOT_SUPPORTED
static final float PROGRESS_NOT_SUPPORTED
- See Also:
- Constant Field Values
-
PROGRESS_COMPLETED
static final float PROGRESS_COMPLETED
- See Also:
- Constant Field Values
-
-
Method Detail
-
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.
-
-