Package com.linkedin.venice.datarecovery

Class DataRecoveryEstimator

java.lang.Object

com.linkedin.venice.datarecovery.DataRecoveryWorker

com.linkedin.venice.datarecovery.DataRecoveryEstimator

public class DataRecoveryEstimator
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
DataRecoveryEstimator()

Method Summary

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

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

getTasks, needWaitForFirstTaskToComplete, perform, shutdownAndAwaitTermination

Methods inherited from class java.lang.Object

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

Constructor Details

DataRecoveryEstimator

public DataRecoveryEstimator()

Method Details

processData

public void processData()

Overrides:

processData in class DataRecoveryWorker

getTotalEstimatedTime

public Long getTotalEstimatedTime()

buildTasks

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

displayTaskResult

public void displayTaskResult(DataRecoveryTask task)