Interface SplitLogManagerCoordination
- All Known Implementing Classes:
ZKSplitLogManagerCoordination
Deprecated.
since 2.4.0 and in 3.0.0, to be removed in 4.0.0, replaced by procedure-based
distributed WAL splitter, see SplitWALManager
Coordination for SplitLogManager. It creates and works with tasks for split log operations
Manager prepares task by calling
Manager prepares task by calling
prepareTask(java.lang.String)
and submit it by
submitTask(String)
. After that it periodically check the number of remaining tasks by
remainingTasksInCoordination()
and waits until it become zero.
Methods required for task life circle:
checkTaskStillAvailable(String)
Check that task is still there
checkTasks()
check for unassigned tasks and resubmit them
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic class
Deprecated.Detail class that shares data between coordination and split log manager -
Method Summary
Modifier and TypeMethodDescriptionvoid
Deprecated.tells Coordination that it should check for new tasksvoid
Deprecated.Check that the task is still therevoid
deleteTask
(String taskName) Deprecated.Deprecated.Returns the configuration that was provided previouslyvoid
init()
Deprecated.Support method to init constants such as timeout.prepareTask
(String taskName) Deprecated.Prepare the new taskint
Deprecated.Return the number of remaining tasksboolean
resubmitTask
(String taskName, SplitLogManager.Task task, SplitLogManager.ResubmitDirective force) Deprecated.Resubmit the task in case if found unassigned or failedvoid
Deprecated.Provide the configuration from the SplitLogManagervoid
submitTask
(String taskName) Deprecated.
-
Method Details
-
setDetails
Deprecated.Provide the configuration from the SplitLogManager -
getDetails
Deprecated.Returns the configuration that was provided previously -
prepareTask
Deprecated.Prepare the new task- Parameters:
taskName
- name of the task- Returns:
- the task id
-
checkTasks
void checkTasks()Deprecated.tells Coordination that it should check for new tasks -
remainingTasksInCoordination
Deprecated.Return the number of remaining tasks -
checkTaskStillAvailable
Deprecated.Check that the task is still there- Parameters:
task
- node to check
-
resubmitTask
boolean resubmitTask(String taskName, SplitLogManager.Task task, SplitLogManager.ResubmitDirective force) Deprecated.Resubmit the task in case if found unassigned or failed- Parameters:
taskName
- path related to tasktask
- to resubmitforce
- whether it should be forced- Returns:
- whether it was successful
-
submitTask
Deprecated.- Parameters:
taskName
- to be submitted
-
deleteTask
Deprecated.- Parameters:
taskName
- to be removed
-
init
Deprecated.Support method to init constants such as timeout. Mostly required for UTs.- Throws:
IOException
-