@Deprecated @InterfaceAudience.Private public final class ZKSplitLog extends Object
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG
Deprecated.
|
Modifier | Constructor and Description |
---|---|
private |
ZKSplitLog()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
(package private) static String |
decode(String s)
Deprecated.
|
(package private) static String |
encode(String s)
Deprecated.
|
static String |
getEncodedNodeName(ZKWatcher zkw,
String filename)
Deprecated.
Gets the full path node name for the log file being split.
|
static String |
getFileName(String node)
Deprecated.
|
static String |
getRescanNode(ZKWatcher zkw)
Deprecated.
|
static org.apache.hadoop.fs.Path |
getSplitLogDir(org.apache.hadoop.fs.Path rootdir,
String tmpname)
Deprecated.
|
static boolean |
isCorrupted(org.apache.hadoop.fs.Path rootdir,
String logFileName,
org.apache.hadoop.fs.FileSystem fs)
Deprecated.
|
static boolean |
isRescanNode(String name)
Deprecated.
|
static boolean |
isRescanNode(ZKWatcher zkw,
String path)
Deprecated.
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)
Deprecated.
|
private static final org.slf4j.Logger LOG
private ZKSplitLog()
public static String getEncodedNodeName(ZKWatcher zkw, String filename)
zkw
- zk referencefilename
- log file name (only the basename)public static String getFileName(String node)
public static String getRescanNode(ZKWatcher zkw)
public static boolean isRescanNode(String name)
name
- the last part in pathpublic static boolean isRescanNode(ZKWatcher zkw, String path)
zkw
- reference to the ZKWatcher
which also contains configuration and constantspath
- the absolute path, starts with '/'public static org.apache.hadoop.fs.Path getSplitLogDir(org.apache.hadoop.fs.Path rootdir, String tmpname)
public static void markCorrupted(org.apache.hadoop.fs.Path rootdir, String logFileName, org.apache.hadoop.fs.FileSystem fs)
public static boolean isCorrupted(org.apache.hadoop.fs.Path rootdir, String logFileName, org.apache.hadoop.fs.FileSystem fs) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.