Class TestReplicationHFileCleaner.FaultyZooKeeperWatcher

java.lang.Object
org.apache.hadoop.hbase.zookeeper.ZKWatcher
org.apache.hadoop.hbase.master.cleaner.TestReplicationHFileCleaner.FaultyZooKeeperWatcher
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.Abortable, org.apache.zookeeper.Watcher
Enclosing class:
TestReplicationHFileCleaner

static class TestReplicationHFileCleaner.FaultyZooKeeperWatcher extends org.apache.hadoop.hbase.zookeeper.ZKWatcher
  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

    org.apache.zookeeper.Watcher.Event, org.apache.zookeeper.Watcher.WatcherType
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper
     

    Fields inherited from class org.apache.hadoop.hbase.zookeeper.ZKWatcher

    abortable
  • Constructor Summary

    Constructors
    Constructor
    Description
    FaultyZooKeeperWatcher(org.apache.hadoop.conf.Configuration conf, String identifier, org.apache.hadoop.hbase.Abortable abortable)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper
     
    void
     

    Methods inherited from class org.apache.hadoop.hbase.zookeeper.ZKWatcher

    abort, checkAndSetZNodeAcls, close, createACL, createACL, getConfiguration, getListeners, getMetaReplicaNodes, getMetaReplicaNodesAndWatchChildren, getNumberOfListeners, getQuorum, getZNodePaths, interruptedException, interruptedExceptionNoThrow, isAborted, isSuperUserId, keeperException, prefix, process, reconnectAfterExpiration, registerListener, registerListenerFirst, syncOrTimeout, toString, unregisterAllListeners, unregisterListener

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.hbase.Abortable

    abort
  • Field Details

    • zk

      private org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper zk
  • Constructor Details

    • FaultyZooKeeperWatcher

      public FaultyZooKeeperWatcher(org.apache.hadoop.conf.Configuration conf, String identifier, org.apache.hadoop.hbase.Abortable abortable) throws org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
      Throws:
      org.apache.hadoop.hbase.ZooKeeperConnectionException
      IOException
  • Method Details

    • init

      public void init() throws Exception
      Throws:
      Exception
    • getRecoverableZooKeeper

      public org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper getRecoverableZooKeeper()
      Overrides:
      getRecoverableZooKeeper in class org.apache.hadoop.hbase.zookeeper.ZKWatcher