Examples of com.alibaba.wasp.zookeeper.FServerTracker

com.alibaba.wasp.zookeeper.FServerTracker
Tracks the online fservers via ZK.
Handling of new RSs checking in is done via RPC. This class is only responsible for watching for expired nodes. It handles listening for changes in the RS node list and watching each node.
If an FS node gets deleted, this automatically handles calling of {@link com.alibaba.wasp.master.FServerManager#expireServer(com.alibaba.wasp.ServerName)}

    this.loadBalancerTracker.start();
    this.assignmentManager = new AssignmentManager(this, serverManager,
        this.balancer, this.executorService, this.metricsMaster);
    zooKeeper.registerListenerFirst(assignmentManager);


    this.fserverTracker = new FServerTracker(zooKeeper, this,
        this.serverManager);
    this.fserverTracker.start();


    this.drainingServerTracker = new DrainingServerTracker(zooKeeper, this,
        this.serverManager);

View Full Code Here

TOP

Related Classes of com.alibaba.wasp.zookeeper.FServerTracker

com.alibaba.wasp.master.FMaster

com.alibaba.wasp.ServerName

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.