Package com.linkedin.venice

Class BatchMaintenanceTaskRunner

java.lang.Object

com.linkedin.venice.BatchMaintenanceTaskRunner

All Implemented Interfaces:

Runnable

public class BatchMaintenanceTaskRunner
extends Object
implements Runnable

This class is a simple runnable which keeps fetching task from list and execute the assigned task. The task fetching and progress tracking / checkpointing is thread-safe, so it can be run in parallel.

Constructor Summary

Constructors

Constructor	Description
BatchMaintenanceTaskRunner(Map<String,Boolean> progressMap, String checkpointFile, List<String> taskList, Function<String,Boolean> storeRunnable)

Method Summary

Modifier and Type	Method	Description
void	checkpoint(String checkpointFile)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

BatchMaintenanceTaskRunner

public BatchMaintenanceTaskRunner(Map<String,Boolean> progressMap,
 String checkpointFile,
 List<String> taskList,
 Function<String,Boolean> storeRunnable)

Method Details

run

public void run()

Specified by:

run in interface Runnable

checkpoint

public void checkpoint(String checkpointFile)