Examples of MasterAddressTracker

com.alibaba.wasp.zookeeper.MasterAddressTracker
Manages the location of the current active FMaster for the FServer.
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.
org.apache.hadoop.hbase.MasterAddressTracker
Manages the location of the current active Master for this 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()}
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.

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

   */
  private void initializeZooKeeper() throws IOException, InterruptedException {
    // Create the master address tracker, register with zk, and start it.  Then
    // block until a master is available.  No point in starting up if no master
    // running.
    this.masterAddressTracker = new MasterAddressTracker(this.zooKeeper, this);
    this.masterAddressTracker.start();
    blockAndCheckIfStopped(this.masterAddressTracker);


    // Wait on cluster being up.  Master will set this flag up in zookeeper
    // when ready.

View Full Code Here

0 1 2 3 4 5

TOP

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.