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

Modifier and Type	Field	Description
protected RedundantExceptionFilter	filter
protected Map<String,com.linkedin.venice.controller.multitaskscheduler.StoreMigrationTask>	migrationTasks

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

executorService

Method Summary

Modifier and Type	Method	Description
void	cleanupMigrationRecord(String storeName)
protected ScheduledExecutorService	createExecutorService(int threadPoolSize)
static StoreMigrationManager	createStoreMigrationManager(int threadPoolSize, int maxRetryAttempts, int delayInSeconds, List<String> childFabricList)
int	getDelayInSeconds()
protected org.apache.logging.log4j.Logger	getLogger()
int	getMaxRetryAttempts()
MigrationRecord	getMigrationRecord(String storeName)
void	pauseMigrationAfter(String storeName, int pauseAfterStep)
void	resumeMigration(String storeName)	Resumes the migration for a specific store from current step
void	resumeMigration(String storeName, int nextStep)	Resumes the migration for a specific store from the next step.
ScheduledFuture<?>	scheduleMigration(String storeName, String sourceCluster, String destinationCluster, int currentStep)
ScheduledFuture<?>	scheduleMigration(String storeName, String sourceCluster, String destinationCluster, int currentStep, int pauseAfterStep, boolean abortOnFailure, ControllerClient srcControllerClient, ControllerClient destControllerClient, Map<String,ControllerClient> srcChildControllerClientMap, Map<String,ControllerClient> destChildControllerClientMap)
ScheduledFuture<?>	scheduleNextStep(MigrationRecord migrationRecord, int delayInSeconds, ControllerClient srcControllerClient, ControllerClient destControllerClient, Map<String,ControllerClient> srcChildControllerClientMap, Map<String,ControllerClient> destChildControllerClientMap)
void	shutdown()

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

scheduleNextStep

Methods inherited from class java.lang.Object

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

Field Details

migrationTasks

protected Map<String,com.linkedin.venice.controller.multitaskscheduler.StoreMigrationTask> migrationTasks

filter

protected RedundantExceptionFilter filter

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,
 int delayInSeconds,
 List<String> childFabricList)

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 pauseAfterStep,
 boolean abortOnFailure,
 ControllerClient srcControllerClient,
 ControllerClient destControllerClient,
 Map<String,ControllerClient> srcChildControllerClientMap,
 Map<String,ControllerClient> destChildControllerClientMap)

scheduleNextStep

public ScheduledFuture<?> scheduleNextStep(MigrationRecord migrationRecord,
 int delayInSeconds,
 ControllerClient srcControllerClient,
 ControllerClient destControllerClient,
 Map<String,ControllerClient> srcChildControllerClientMap,
 Map<String,ControllerClient> destChildControllerClientMap)

pauseMigrationAfter

public void pauseMigrationAfter(String storeName,
 int pauseAfterStep)

resumeMigration

public void resumeMigration(String storeName)

Resumes the migration for a specific store from current step

Parameters:

storeName -

resumeMigration

public void resumeMigration(String storeName,
 int nextStep)

Resumes the migration for a specific store from the next step.

Parameters:

storeName -

nextStep -

cleanupMigrationRecord

public void cleanupMigrationRecord(String storeName)

getMaxRetryAttempts

public int getMaxRetryAttempts()

getDelayInSeconds

public int getDelayInSeconds()

shutdown

public void shutdown()

Overrides:

shutdown in class ScheduledTaskManager