Examples of ZooKeeperAnnouncer


Examples of com.linkedin.d2.balancer.servers.ZooKeeperAnnouncer

    ZooKeeperAnnouncer[] zkAnnouncers = new ZooKeeperAnnouncer[d2ServersConfigs.size()];
    for (int i = 0; i < d2ServersConfigs.size(); i++)
    {
      Map<String, Object> d2ServerConfig = d2ServersConfigs.get(i);
      ZooKeeperServer server = new ZooKeeperServer();
      ZooKeeperAnnouncer announcer = new ZooKeeperAnnouncer(server);
      Map<String, Object> partitionDataMap = (Map<String, Object>)
          d2ServerConfig.get("partitionData");
      announcer.setCluster((String) d2ServerConfig.get("d2Cluster"));
      announcer.setUri((String)d2ServerConfig.get("serverUri"));
      announcer.setWeightOrPartitionData(PartitionDataFactory.
                                                createPartitionDataMap(partitionDataMap));
      zkAnnouncers[i] = announcer;
    }
    return zkAnnouncers;
  }
View Full Code Here

Examples of com.linkedin.d2.balancer.servers.ZooKeeperAnnouncer

    ZooKeeperAnnouncer[] zkAnnouncers = new ZooKeeperAnnouncer[d2ServersConfigs.size()];
    for (int i = 0; i < d2ServersConfigs.size(); i++)
    {
      Map<String, Object> d2ServerConfig = d2ServersConfigs.get(i);
      ZooKeeperServer server = new ZooKeeperServer();
      ZooKeeperAnnouncer announcer = new ZooKeeperAnnouncer(server);
      Map<String, Object> partitionDataMap = (Map<String, Object>)
          d2ServerConfig.get("partitionData");
      announcer.setCluster((String) d2ServerConfig.get("d2Cluster"));
      announcer.setUri((String)d2ServerConfig.get("serverUri"));
      announcer.setWeightOrPartitionData(PartitionDataFactory.
                                                createPartitionDataMap(partitionDataMap));
      zkAnnouncers[i] = announcer;
    }
    return zkAnnouncers;
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.