Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

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)

• encode

  static String encode(String s)

• decode

  static String decode(String s)

• 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/<current region encoded name> exists. Returns true if exists and set watcher as well.

  Parameters:

  zkw -

  regionEncodedName - region encode name

  Returns:

  true when /hbase/recovering-regions/<current region encoded name> 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 org.apache.hadoop.hbase.protobuf.generated.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