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.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ZKSplitLog()

Method Summary

Modifier and Type	Method and Description
(package private) static String	decode(String s)
(package private) static String	encode(String s)
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

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

ZKSplitLog

private ZKSplitLog()

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)

encode

static String encode(String s)

decode

static String decode(String s)

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