DataRecoveryWorker (venice API)

java.lang.Object

com.linkedin.venice.datarecovery.DataRecoveryWorker

Direct Known Subclasses:: DataRecoveryEstimator, DataRecoveryExecutor, DataRecoveryMonitor

public abstract class DataRecoveryWorker extends Object

Field Summary

Fields

Modifier and Type

Field

Description

protected int

interval

static final int

INTERVAL_UNSET

protected final ExecutorService

pool

protected final int

poolSize

protected List<DataRecoveryTask>

tasks
Constructor Summary

Constructors

Constructor

Description

DataRecoveryWorker()

DataRecoveryWorker(int poolSize)
Method Summary

Modifier and Type

Method

Description

List<DataRecoveryTask>

getTasks()

boolean

needWaitForFirstTaskToComplete(DataRecoveryTask task)

For some task, it is benefit to wait for the first task to complete before starting to run the remaining ones.

void

perform(Set<String> storeNames, Command.Params params)

void

processData()

void

shutdownAndAwaitTermination()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- INTERVAL_UNSET
  
  public static final int INTERVAL_UNSET
  See Also:
  
  Constant Field Values
- poolSize
  
  protected final int poolSize
- interval
  
  protected int interval
- pool
  
  protected final ExecutorService pool
- tasks
  
  protected List<DataRecoveryTask> tasks
Constructor Details
- DataRecoveryWorker
  
  public DataRecoveryWorker()
- DataRecoveryWorker
  
  public DataRecoveryWorker(int poolSize)
Method Details
- getTasks
  
  public List<DataRecoveryTask> getTasks()
- needWaitForFirstTaskToComplete
  
  public boolean needWaitForFirstTaskToComplete(DataRecoveryTask task)
  
  For some task, it is benefit to wait for the first task to complete before starting to run the remaining ones. e.g. the first run of task can set up local session files that can be used by follow-up tasks.
- perform
  
  public void perform(Set<String> storeNames, Command.Params params)
- processData
  
  public void processData()
- shutdownAndAwaitTermination
  
  public void shutdownAndAwaitTermination()