Package com.linkedin.venice.datarecovery

Class DataRecoveryExecutor

java.lang.Object

com.linkedin.venice.datarecovery.DataRecoveryWorker

com.linkedin.venice.datarecovery.DataRecoveryExecutor

public class DataRecoveryExecutor
extends DataRecoveryWorker

DataRecoveryExecutor is the engine to run tasks in data recovery.

Field Summary

Fields inherited from class com.linkedin.venice.datarecovery.DataRecoveryWorker

interval, INTERVAL_UNSET, pool, poolSize, tasks

Constructor Summary

Constructors

Constructor	Description
DataRecoveryExecutor()

Method Summary

Modifier and Type	Method	Description
List<DataRecoveryTask>	buildTasks(Set<String> storeNames, Command.Params params)
void	displayTaskResult(DataRecoveryTask task)

Methods inherited from class com.linkedin.venice.datarecovery.DataRecoveryWorker

getTasks, needWaitForFirstTaskToComplete, perform, processData, shutdownAndAwaitTermination

Methods inherited from class java.lang.Object

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

Constructor Details

DataRecoveryExecutor

public DataRecoveryExecutor()

Method Details

buildTasks

public List<DataRecoveryTask> buildTasks(Set<String> storeNames,
 Command.Params params)

displayTaskResult

public void displayTaskResult(DataRecoveryTask task)