org.apache.hadoop.hbase.master.cleaner

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

Field Summary

Fields

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

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

abortable

Constructor Summary

Constructors

Constructor and Description
FaultyZooKeeperWatcher(org.apache.hadoop.conf.Configuration conf, String identifier, org.apache.hadoop.hbase.Abortable abortable)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper	getRecoverableZooKeeper()
void	init()

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

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

Methods inherited from class java.lang.Object

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

Field Detail

zk

private org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper zk

Constructor Detail

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 Detail

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