Package com.linkedin.venice.datarecovery

Class DataRecoveryTask

java.lang.Object

com.linkedin.venice.datarecovery.DataRecoveryTask

All Implemented Interfaces:

Runnable

public class DataRecoveryTask
extends Object
implements 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

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DataRecoveryTask

public DataRecoveryTask(Command command,
 DataRecoveryTask.TaskParams params)

Method Details

run

public void run()

Specified by:

run in interface 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()