Examples of org.apache.hadoop.hbase.zookeeper.MasterAddressTracker

Package org.apache.hadoop.hbase.zookeeper

Examples of org.apache.hadoop.hbase.zookeeper.MasterAddressTracker

org.apache.hadoop.hbase.zookeeper.MasterAddressTracker
Manages the location of the current active Master for the RegionServer.
Listens for ZooKeeper events related to the master address. The node /master will contain the address of the current master. This listener is interested in NodeDeleted and NodeCreated events on /master.
Utilizes {@link ZooKeeperNodeTracker} for zk interactions.
You can get the current master via {@link #getMasterAddress()} or via{@link #getMasterAddress(ZooKeeperWatcher)} if you do not have a runninginstance of this Tracker in your context.
This class also includes utility for interacting with the master znode, for writing and reading the znode content.

    ZooKeeperWatcher zkw = Mockito.mock(ZooKeeperWatcher.class);
    Mockito.doReturn("fakequorum").when(zkw).getQuorum();
    Mockito.doReturn(zkw).when(rs).getZooKeeper();


    // Fake MasterAddressTracker
    MasterAddressTracker mat = Mockito.mock(MasterAddressTracker.class);
    Mockito.doReturn(fakeMasterAddress).when(mat).getMasterAddress();
    Mockito.doReturn(mat).when(rs).getMasterAddressTracker();


    MetricsRegionServer rms = Mockito.mock(MetricsRegionServer.class);
    Mockito.doReturn(new MetricsRegionServerWrapperStub()).when(rms).getRegionServerWrapper();

View Full Code Here

    ZooKeeperWatcher zkw = Mockito.mock(ZooKeeperWatcher.class);
    Mockito.doReturn("fakequorum").when(zkw).getQuorum();
    Mockito.doReturn(zkw).when(master).getZooKeeper();


    // Fake MasterAddressTracker
    MasterAddressTracker tracker = Mockito.mock(MasterAddressTracker.class);
    Mockito.doReturn(tracker).when(master).getMasterAddressTracker();
    Mockito.doReturn(FAKE_HOST).when(tracker).getMasterAddress();


    MetricsRegionServer rms = Mockito.mock(MetricsRegionServer.class);
    Mockito.doReturn(new MetricsRegionServerWrapperStub()).when(rms).getRegionServerWrapper();

View Full Code Here

0 1 2 3 4

TOP

Related Classes of org.apache.hadoop.hbase.zookeeper.MasterAddressTracker

org.apache.hadoop.hbase.master.HMaster

org.apache.hadoop.hbase.master.TestMasterStatusServlet

org.apache.hadoop.hbase.regionserver.HRegionServer

org.apache.hadoop.hbase.regionserver.TestMasterAddressManager

org.apache.hadoop.hbase.regionserver.TestMasterAddressTracker

org.apache.hadoop.hbase.regionserver.TestRSStatusServlet

org.apache.hadoop.hbase.ServerName

org.apache.zookeeper.data.Stat

org.apache.hadoop.hbase.exceptions.DeserializationException

java.io.InterruptedIOException

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.