Package com.linkedin.venice.datarecovery
Class DataRecoveryTask
- java.lang.Object
-
- com.linkedin.venice.datarecovery.DataRecoveryTask
-
- All Implemented Interfaces:
java.lang.Runnable
public class DataRecoveryTask extends java.lang.Object implements java.lang.Runnable
A Task is wrapper class that designed to execute multiple commands in sequence.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
DataRecoveryTask.TaskParams
static class
DataRecoveryTask.TaskResult
-
Constructor Summary
Constructors Constructor Description DataRecoveryTask(Command command, DataRecoveryTask.TaskParams params)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Command
getCommand()
DataRecoveryTask.TaskParams
getTaskParams()
DataRecoveryTask.TaskResult
getTaskResult()
boolean
needWaitForFirstTaskToComplete()
For some task, it is benefit to wait for the first task to complete before starting to run the remaining ones.void
run()
-
-
-
Constructor Detail
-
DataRecoveryTask
public DataRecoveryTask(Command command, DataRecoveryTask.TaskParams params)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
needWaitForFirstTaskToComplete
public boolean needWaitForFirstTaskToComplete()
For some task, it is benefit to wait for the first task to complete before starting to run the remaining ones. Thus, this is a task specific flag to set based on the purpose of the task.
-
getTaskResult
public DataRecoveryTask.TaskResult getTaskResult()
-
getCommand
public Command getCommand()
-
getTaskParams
public DataRecoveryTask.TaskParams getTaskParams()
-
-