本文整理了Java中org.apache.hadoop.hbase.zookeeper.ZKClusterId.setClusterId()方法的一些代码示例，展示了ZKClusterId.setClusterId()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKClusterId.setClusterId()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.zookeeper.ZKClusterId
类名称：ZKClusterId
方法名：setClusterId

ZKClusterId.setClusterId介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

private static String initPeerClusterState(String baseZKNode)
  throws IOException, KeeperException {
 // Add a dummy region server and set up the cluster id
 Configuration testConf = new Configuration(conf);
 testConf.set(HConstants.ZOOKEEPER_ZNODE_PARENT, baseZKNode);
 ZKWatcher zkw1 = new ZKWatcher(testConf, "test1", null);
 String fakeRs = ZNodePaths.joinZNode(zkw1.getZNodePaths().rsZNode,
     "hostname1.example.org:1234");
 ZKUtil.createWithParents(zkw1, fakeRs);
 ZKClusterId.setClusterId(zkw1, new ClusterId());
 return ZKConfig.getZooKeeperClusterKey(testConf);
}

代码示例来源：origin: apache/hbase

ZKClusterId.setClusterId(server.getZooKeeper(), clusterId);
secretManager = (AuthenticationTokenSecretManager)server.getSecretManager();
while(secretManager.getCurrentKey() == null) {

代码示例来源：origin: apache/hbase

ZKClusterId.setClusterId(this.zooKeeper, fileSystemManager.getClusterId());
this.clusterId = clusterId.toString();

代码示例来源：origin: apache/hbase

this.masterAddressSyncer.start();
ZKClusterId.setClusterId(clientZkWatcher, fileSystemManager.getClusterId());

代码示例来源：origin: apache/hbase

@Before
public void setUp() throws Exception {
 zkw = HBaseTestingUtility.getZooKeeperWatcher(utility);
 String fakeRs1 = ZNodePaths.joinZNode(zkw.getZNodePaths().rsZNode,
     "hostname1.example.org:1234");
 try {
  ZKClusterId.setClusterId(zkw, new ClusterId());
  rp = ReplicationFactory.getReplicationPeers(zkw, conf);
  rp.init();
  rt = ReplicationFactory.getReplicationTracker(zkw, new DummyServer(fakeRs1),
   new DummyServer(fakeRs1));
 } catch (Exception e) {
  fail("Exception during test setup: " + e);
 }
 rsRemovedCount = new AtomicInteger(0);
 rsRemovedData = "";
}

代码示例来源：origin: apache/hbase

ZKUtil.setData(zkw, "/hbase/replication/state", ZKReplicationPeerStorage.ENABLED_ZNODE_BYTES);
ZKClusterId.setClusterId(zkw, new ClusterId());
FSUtils.setRootDir(utility.getConfiguration(), utility.getDataTestDir());
fs = FileSystem.get(conf);

代码示例来源：origin: org.apache.hbase/hbase-server

ZKClusterId.setClusterId(server.getZooKeeper(), clusterId);
secretManager = (AuthenticationTokenSecretManager)server.getSecretManager();
while(secretManager.getCurrentKey() == null) {

代码示例来源：origin: org.apache.hbase/hbase-server

ZKUtil.setData(zkw, "/hbase/replication/state", ZKReplicationPeerStorage.ENABLED_ZNODE_BYTES);
ZKClusterId.setClusterId(zkw, new ClusterId());
FSUtils.setRootDir(utility.getConfiguration(), utility.getDataTestDir());
fs = FileSystem.get(conf);

代码示例来源：origin: org.apache.hbase/hbase-server

@Before
public void setUp() throws Exception {
 zkw = HBaseTestingUtility.getZooKeeperWatcher(utility);
 String fakeRs1 = ZNodePaths.joinZNode(zkw.getZNodePaths().rsZNode,
     "hostname1.example.org:1234");
 try {
  ZKClusterId.setClusterId(zkw, new ClusterId());
  rp = ReplicationFactory.getReplicationPeers(zkw, conf);
  rp.init();
  rt = ReplicationFactory.getReplicationTracker(zkw, new DummyServer(fakeRs1),
   new DummyServer(fakeRs1));
 } catch (Exception e) {
  fail("Exception during test setup: " + e);
 }
 rsRemovedCount = new AtomicInteger(0);
 rsRemovedData = "";
}

代码示例来源：origin: harbby/presto-connectors

ZKClusterId.setClusterId(this.zooKeeper, fileSystemManager.getClusterId());
this.serverManager = createServerManager(this, this);