Interface TaskManagerActions
-
public interface TaskManagerActions
Interface for the communication of theTask
with theTaskExecutor
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
failTask(ExecutionAttemptID executionAttemptID, Throwable cause)
Tells the task manager to fail the given task.void
notifyEndOfData(ExecutionAttemptID executionAttemptID)
Notifies that the task has reached the end of data.void
notifyFatalError(String message, Throwable cause)
Notifies the task manager about a fatal error occurred in the task.void
updateTaskExecutionState(TaskExecutionState taskExecutionState)
Notifies the task manager about the task execution state update.
-
-
-
Method Detail
-
notifyFatalError
void notifyFatalError(String message, Throwable cause)
Notifies the task manager about a fatal error occurred in the task.- Parameters:
message
- Message to reportcause
- Cause of the fatal error
-
failTask
void failTask(ExecutionAttemptID executionAttemptID, Throwable cause)
Tells the task manager to fail the given task.- Parameters:
executionAttemptID
- Execution attempt ID of the task to failcause
- Cause of the failure
-
updateTaskExecutionState
void updateTaskExecutionState(TaskExecutionState taskExecutionState)
Notifies the task manager about the task execution state update.- Parameters:
taskExecutionState
- Task execution state update
-
notifyEndOfData
void notifyEndOfData(ExecutionAttemptID executionAttemptID)
Notifies that the task has reached the end of data.- Parameters:
executionAttemptID
- Execution attempt ID of the task.
-
-