org.apache.hadoop.hbase.zookeeper

Class ZKSplitLog

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZKSplitLog

@InterfaceAudience.Private
public class ZKSplitLog
extends Object

Common methods and attributes used by SplitLogManager and SplitLogWorker running distributed splitting of WAL logs.

Constructor Summary

Constructors

Constructor and Description
ZKSplitLog()

Method Summary

Methods

Modifier and Type	Method and Description
static void	deleteRecoveringRegionZNodes(ZooKeeperWatcher watcher, List<String> regions)
static String	getEncodedNodeName(ZooKeeperWatcher zkw, String filename) Gets the full path node name for the log file being split.
static String	getFileName(String node)
static ClusterStatusProtos.RegionStoreSequenceIds	getRegionFlushedSequenceId(ZooKeeperWatcher zkw, String serverName, String encodedRegionName) This function is used in distributedLogReplay to fetch last flushed sequence id from ZK
static String	getRescanNode(ZooKeeperWatcher zkw)
static org.apache.hadoop.fs.Path	getSplitLogDir(org.apache.hadoop.fs.Path rootdir, String tmpname)
static String	getSplitLogDirTmpComponent(String worker, String file)
static boolean	isCorrupted(org.apache.hadoop.fs.Path rootdir, String logFileName, org.apache.hadoop.fs.FileSystem fs)
static boolean	isRegionMarkedRecoveringInZK(ZooKeeperWatcher zkw, String regionEncodedName) check if /hbase/recovering-regions/ exists.
static boolean	isRescanNode(String name)
static boolean	isRescanNode(ZooKeeperWatcher zkw, String path)
static boolean	isTaskPath(ZooKeeperWatcher zkw, String path)
static void	markCorrupted(org.apache.hadoop.fs.Path rootdir, String logFileName, org.apache.hadoop.fs.FileSystem fs)
static long	parseLastFlushedSequenceIdFrom(byte[] bytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKSplitLog

public ZKSplitLog()

Method Detail

getEncodedNodeName

public static String getEncodedNodeName(ZooKeeperWatcher zkw,
                        String filename)

Gets the full path node name for the log file being split. This method will url encode the filename.

Parameters:

zkw - zk reference

filename - log file name (only the basename)

getFileName

public static String getFileName(String node)

getRescanNode

public static String getRescanNode(ZooKeeperWatcher zkw)

isRescanNode

public static boolean isRescanNode(String name)

Parameters:

name - the last part in path

Returns:

whether the node name represents a rescan node

isRescanNode

public static boolean isRescanNode(ZooKeeperWatcher zkw,
                   String path)

Parameters:

zkw -

path - the absolute path, starts with '/'

Returns:

whether the path represents a rescan node

isTaskPath

public static boolean isTaskPath(ZooKeeperWatcher zkw,
                 String path)

getSplitLogDir

public static org.apache.hadoop.fs.Path getSplitLogDir(org.apache.hadoop.fs.Path rootdir,
                                       String tmpname)

getSplitLogDirTmpComponent

public static String getSplitLogDirTmpComponent(String worker,
                                String file)

markCorrupted

public static void markCorrupted(org.apache.hadoop.fs.Path rootdir,
                 String logFileName,
                 org.apache.hadoop.fs.FileSystem fs)

isCorrupted

public static boolean isCorrupted(org.apache.hadoop.fs.Path rootdir,
                  String logFileName,
                  org.apache.hadoop.fs.FileSystem fs)
                           throws IOException

Throws:

IOException

isRegionMarkedRecoveringInZK

public static boolean isRegionMarkedRecoveringInZK(ZooKeeperWatcher zkw,
                                   String regionEncodedName)
                                            throws org.apache.zookeeper.KeeperException

check if /hbase/recovering-regions/ exists. Returns true if exists and set watcher as well.

Parameters:

zkw -

regionEncodedName - region encode name

Returns:

true when /hbase/recovering-regions/ exists

Throws:

org.apache.zookeeper.KeeperException

parseLastFlushedSequenceIdFrom

public static long parseLastFlushedSequenceIdFrom(byte[] bytes)

Parameters:

bytes - - Content of a failed region server or recovering region znode.

Returns:

long - The last flushed sequence Id for the region server

deleteRecoveringRegionZNodes

public static void deleteRecoveringRegionZNodes(ZooKeeperWatcher watcher,
                                List<String> regions)

getRegionFlushedSequenceId

public static ClusterStatusProtos.RegionStoreSequenceIds getRegionFlushedSequenceId(ZooKeeperWatcher zkw,
                                                                    String serverName,
                                                                    String encodedRegionName)
                                                                             throws IOException

This function is used in distributedLogReplay to fetch last flushed sequence id from ZK

Parameters:

zkw -

serverName -

encodedRegionName -

Returns:

the last flushed sequence ids recorded in ZK of the region for serverName

Throws:

IOException