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
java.util.List<DataRecoveryTask>	buildTasks(java.util.Set<java.lang.String> storeNames, Command.Params params)
void	displayTaskResult(DataRecoveryTask task)
java.lang.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 Detail

DataRecoveryEstimator

public DataRecoveryEstimator()

Method Detail

processData

public void processData()

Overrides:

processData in class DataRecoveryWorker

getTotalEstimatedTime

public java.lang.Long getTotalEstimatedTime()

buildTasks

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

displayTaskResult

public void displayTaskResult(DataRecoveryTask task)