org.apache.hadoop.hbase.coordination

Class ZkSplitLogWorkerCoordination.ZkSplitTaskDetails

java.lang.Object

org.apache.hadoop.hbase.coordination.ZkSplitLogWorkerCoordination.ZkSplitTaskDetails

All Implemented Interfaces:

SplitLogWorkerCoordination.SplitTaskDetails

Enclosing class:

ZkSplitLogWorkerCoordination

public static class ZkSplitLogWorkerCoordination.ZkSplitTaskDetails
extends Object
implements SplitLogWorkerCoordination.SplitTaskDetails

When ZK-based implementation wants to complete the task, it needs to know task znode and current znode cversion (needed for subsequent update operation).

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.commons.lang3.mutable.MutableInt	curTaskZKVersion
private String	taskNode

Constructor Summary

Constructors

Constructor and Description
ZkSplitTaskDetails()
ZkSplitTaskDetails(String taskNode, org.apache.commons.lang3.mutable.MutableInt curTaskZKVersion)

Method Summary

Modifier and Type	Method and Description
org.apache.commons.lang3.mutable.MutableInt	getCurTaskZKVersion()
String	getTaskNode()
String	getWALFile()
void	setCurTaskZKVersion(org.apache.commons.lang3.mutable.MutableInt curTaskZKVersion)
void	setTaskNode(String taskNode)

Methods inherited from class java.lang.Object

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

Field Detail

taskNode

private String taskNode

curTaskZKVersion

private org.apache.commons.lang3.mutable.MutableInt curTaskZKVersion

Constructor Detail

ZkSplitTaskDetails

public ZkSplitTaskDetails()

ZkSplitTaskDetails

public ZkSplitTaskDetails(String taskNode,
                          org.apache.commons.lang3.mutable.MutableInt curTaskZKVersion)

Method Detail

getTaskNode

public String getTaskNode()

setTaskNode

public void setTaskNode(String taskNode)

getCurTaskZKVersion

public org.apache.commons.lang3.mutable.MutableInt getCurTaskZKVersion()

setCurTaskZKVersion

public void setCurTaskZKVersion(org.apache.commons.lang3.mutable.MutableInt curTaskZKVersion)

getWALFile

public String getWALFile()

Specified by:

getWALFile in interface SplitLogWorkerCoordination.SplitTaskDetails

Returns:

full file path in HDFS for the WAL file to be split.