Package com.linkedin.venice.controller.multitaskscheduler

Class StoreMigrationManager

java.lang.Object

com.linkedin.venice.controller.multitaskscheduler.ScheduledTaskManager

com.linkedin.venice.controller.multitaskscheduler.StoreMigrationManager

public class StoreMigrationManager
extends ScheduledTaskManager

Field Summary

Fields inherited from class com.linkedin.venice.controller.multitaskscheduler.ScheduledTaskManager

executorService

Constructor Summary

Constructors

Constructor	Description
StoreMigrationManager(int threadPoolSize, int maxRetryAttempts)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	cleanupMigrationRecord(String storeName)
protected ScheduledExecutorService	createExecutorService(int threadPoolSize)
static StoreMigrationManager	createStoreMigrationManager(int threadPoolSize, int maxRetryAttempts)
protected org.apache.logging.log4j.Logger	getLogger()
int	getMaxRetryAttempts()
MigrationRecord	getMigrationRecord(String storeName)
ScheduledFuture<?>	scheduleMigration(String storeName, String sourceCluster, String destinationCluster, int currentStep)
ScheduledFuture<?>	scheduleMigration(String storeName, String sourceCluster, String destinationCluster, int currentStep, int delayInSeconds, boolean abortOnFailure)
ScheduledFuture<?>	scheduleNextStep(MigrationRecord record, int delayInSeconds)

Methods inherited from class com.linkedin.venice.controller.multitaskscheduler.ScheduledTaskManager

scheduleNextStep, shutdown

Methods inherited from class java.lang.Object

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

Constructor Details

StoreMigrationManager

@Deprecated
public StoreMigrationManager(int threadPoolSize,
 int maxRetryAttempts)

Deprecated.

Constructor to initialize the StoreMigrationManager with the specified thread pool size and max retry attempts. Only used for testing purpose, please use createStoreMigrationManager instead.

Parameters:

threadPoolSize -

maxRetryAttempts -

Method Details

getMigrationRecord

public MigrationRecord getMigrationRecord(String storeName)

createExecutorService

protected ScheduledExecutorService createExecutorService(int threadPoolSize)

Specified by:

createExecutorService in class ScheduledTaskManager

getLogger

protected org.apache.logging.log4j.Logger getLogger()

Specified by:

getLogger in class ScheduledTaskManager

createStoreMigrationManager

public static StoreMigrationManager createStoreMigrationManager(int threadPoolSize,
 int maxRetryAttempts)

scheduleMigration

public ScheduledFuture<?> scheduleMigration(String storeName,
 String sourceCluster,
 String destinationCluster,
 int currentStep)

scheduleMigration

public ScheduledFuture<?> scheduleMigration(String storeName,
 String sourceCluster,
 String destinationCluster,
 int currentStep,
 int delayInSeconds,
 boolean abortOnFailure)

scheduleNextStep

public ScheduledFuture<?> scheduleNextStep(MigrationRecord record,
 int delayInSeconds)

cleanupMigrationRecord

public void cleanupMigrationRecord(String storeName)

getMaxRetryAttempts

public int getMaxRetryAttempts()