Class StoreMigrationManager
java.lang.Object
com.linkedin.venice.controller.multitaskscheduler.ScheduledTaskManager
com.linkedin.venice.controller.multitaskscheduler.StoreMigrationManager
-
Field Summary
FieldsFields inherited from class com.linkedin.venice.controller.multitaskscheduler.ScheduledTaskManager
executorService -
Method Summary
Modifier and TypeMethodDescriptionvoidcleanupMigrationRecord(String storeName) protected ScheduledExecutorServicecreateExecutorService(int threadPoolSize) static StoreMigrationManagercreateStoreMigrationManager(int threadPoolSize, int maxRetryAttempts, int delayInSeconds, List<String> childFabricList) intprotected org.apache.logging.log4j.LoggerintgetMigrationRecord(String storeName) voidpauseMigrationAfter(String storeName, int pauseAfterStep) voidresumeMigration(String storeName) Resumes the migration for a specific store from current stepvoidresumeMigration(String storeName, int nextStep) Resumes the migration for a specific store from the next step.scheduleMigration(String storeName, String sourceCluster, String destinationCluster, int currentStep) 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(MigrationRecord migrationRecord, int delayInSeconds, ControllerClient srcControllerClient, ControllerClient destControllerClient, Map<String, ControllerClient> srcChildControllerClientMap, Map<String, ControllerClient> destChildControllerClientMap) voidshutdown()Methods inherited from class com.linkedin.venice.controller.multitaskscheduler.ScheduledTaskManager
scheduleNextStep
-
Field Details
-
migrationTasks
-
filter
-
-
Method Details
-
getMigrationRecord
-
createExecutorService
- Specified by:
createExecutorServicein classScheduledTaskManager
-
getLogger
protected org.apache.logging.log4j.Logger getLogger()- Specified by:
getLoggerin classScheduledTaskManager
-
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
-
resumeMigration
Resumes the migration for a specific store from current step- Parameters:
storeName-
-
resumeMigration
Resumes the migration for a specific store from the next step.- Parameters:
storeName-nextStep-
-
cleanupMigrationRecord
-
getMaxRetryAttempts
public int getMaxRetryAttempts() -
getDelayInSeconds
public int getDelayInSeconds() -
shutdown
public void shutdown()- Overrides:
shutdownin classScheduledTaskManager
-