Class ZKSplitLog

java.lang.Object
org.apache.hadoop.hbase.zookeeper.ZKSplitLog

@Deprecated @Private public final class ZKSplitLog extends Object
Deprecated.
since 2.4.0 and 3.0.0 replaced by procedure-based WAL splitting; see SplitWALManager.
Common methods and attributes used by SplitLogManager and SplitLogWorker running distributed splitting of WAL logs.
  • Field Details

    • LOG

      private static final org.slf4j.Logger LOG
      Deprecated.
  • Constructor Details

  • Method Details

    • getEncodedNodeName

      public static String getEncodedNodeName(ZKWatcher zkw, String filename)
      Deprecated.
      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)
      Deprecated.
    • encode

      static String encode(String s)
      Deprecated.
    • decode

      static String decode(String s)
      Deprecated.
    • getRescanNode

      public static String getRescanNode(ZKWatcher zkw)
      Deprecated.
    • isRescanNode

      public static boolean isRescanNode(String name)
      Deprecated.
      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)
      Deprecated.
      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)
      Deprecated.
    • markCorrupted

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

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