org.apache.hadoop.hbase.coordination

Interface SplitLogManagerCoordination

All Known Implementing Classes:

ZKSplitLogManagerCoordination

@InterfaceAudience.Private
public interface SplitLogManagerCoordination

Coordination for SplitLogManager. It creates and works with tasks for split log operations
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

Nested Classes

Modifier and Type	Interface and Description
static class	SplitLogManagerCoordination.SplitLogManagerDetails Detail class that shares data between coordination and split log manager

Method Summary

Modifier and Type	Method and Description
void	checkTasks() tells Coordination that it should check for new tasks
void	checkTaskStillAvailable(String task) Check that the task is still there
void	deleteTask(String taskName)
SplitLogManagerCoordination.SplitLogManagerDetails	getDetails() Returns the configuration that was provided previously
void	init() Support method to init constants such as timeout.
String	prepareTask(String taskName) Prepare the new task
int	remainingTasksInCoordination() Return the number of remaining tasks
boolean	resubmitTask(String taskName, SplitLogManager.Task task, SplitLogManager.ResubmitDirective force) Resubmit the task in case if found unassigned or failed
void	setDetails(SplitLogManagerCoordination.SplitLogManagerDetails details) Provide the configuration from the SplitLogManager
void	submitTask(String taskName)

Method Detail

setDetails

void setDetails(SplitLogManagerCoordination.SplitLogManagerDetails details)

Provide the configuration from the SplitLogManager

getDetails

SplitLogManagerCoordination.SplitLogManagerDetails getDetails()

Returns the configuration that was provided previously

prepareTask

String prepareTask(String taskName)

Prepare the new task

Parameters:

taskName - name of the task

Returns:

the task id

checkTasks

void checkTasks()

tells Coordination that it should check for new tasks

remainingTasksInCoordination

int remainingTasksInCoordination()

Return the number of remaining tasks

checkTaskStillAvailable

void checkTaskStillAvailable(String task)

Check that the task is still there

Parameters:

task - node to check

resubmitTask

boolean resubmitTask(String taskName,
                     SplitLogManager.Task task,
                     SplitLogManager.ResubmitDirective force)

Resubmit the task in case if found unassigned or failed

Parameters:

taskName - path related to task

task - to resubmit

force - whether it should be forced

Returns:

whether it was successful

submitTask

void submitTask(String taskName)

Parameters:

taskName - to be submitted

deleteTask

void deleteTask(String taskName)

Parameters:

taskName - to be removed

init

void init()
   throws IOException

Support method to init constants such as timeout. Mostly required for UTs.

Throws:

IOException