org.apache.hadoop.hbase.zookeeper

Class ZKSplitLog

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZKSplitLog

@InterfaceAudience.Private
public final class ZKSplitLog
extends Object

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

Method Summary

Modifier and Type	Method and Description
static String	getEncodedNodeName(ZKWatcher zkw, String filename) Gets the full path node name for the log file being split.
static String	getFileName(String node)
static String	getRescanNode(ZKWatcher zkw)
static org.apache.hadoop.fs.Path	getSplitLogDir(org.apache.hadoop.fs.Path rootdir, String tmpname)
static boolean	isCorrupted(org.apache.hadoop.fs.Path rootdir, String logFileName, org.apache.hadoop.fs.FileSystem fs)
static boolean	isRescanNode(String name)
static boolean	isRescanNode(ZKWatcher zkw, String path) Checks if the given path represents a rescan node.
static void	markCorrupted(org.apache.hadoop.fs.Path rootdir, String logFileName, org.apache.hadoop.fs.FileSystem fs)

Methods inherited from class java.lang.Object

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

Method Detail

getEncodedNodeName

public static String getEncodedNodeName(ZKWatcher 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(ZKWatcher 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(ZKWatcher zkw,
                                   String path)

Checks if the given path represents a rescan node.

Parameters:

zkw - reference to the ZKWatcher which also contains configuration and constants

path - the absolute path, starts with '/'

Returns:

whether the path represents a rescan node

getSplitLogDir

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

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