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
java.util.List<DataRecoveryTask>	buildTasks(java.util.Set<java.lang.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 Detail

DataRecoveryExecutor

public DataRecoveryExecutor()

Method Detail

buildTasks

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

displayTaskResult

public void displayTaskResult(DataRecoveryTask task)