org.apache.hadoop.hbase.zookeeper.ZKWatcher.getQuorum()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(86)

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

ZKWatcher.getQuorum介绍

[英]Get the quorum address of this instance.
[中]获取此实例的仲裁地址。

代码示例

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

@Override
public String getZookeeperQuorum() {
 ZKWatcher zk = master.getZooKeeper();
 if (zk == null) {
  return "";
 }
 return zk.getQuorum();
}

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

@Override
public String getZookeeperQuorum() {
 ZKWatcher zk = regionServer.getZooKeeper();
 if (zk == null) {
  return "";
 }
 return zk.getQuorum();
}

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

public String formatZKString() {
 StringBuilder quorums = new StringBuilder();
 String zkQuorum = master.getZooKeeper().getQuorum();
 if (null == zkQuorum) {
  return quorums.toString();
 }
 String[] zks = zkQuorum.split(",");
 if (zks.length == 0) {
  return quorums.toString();
 }
 for(int i = 0; i < zks.length; ++i) {
  quorums.append(zks[i].trim());
  if (i != (zks.length - 1)) {
   quorums.append("<br/>");
  }
 }
 return quorums.toString();
}

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

String[] servers = zkw.getQuorum().split(",");
for (String server : servers) {
 sb.append("\n ").append(server);

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

private static void resetAcls(final Configuration conf, boolean eraseAcls)
  throws Exception {
 ZKWatcher zkw = new ZKWatcher(conf, "ZKAclReset", null);
 try {
  LOG.info((eraseAcls ? "Erase" : "Set") + " HBase ACLs for " +
       zkw.getQuorum() + " " + zkw.getZNodePaths().baseZNode);
  resetAcls(zkw, zkw.getZNodePaths().baseZNode, eraseAcls);
 } finally {
  zkw.close();
 }
}

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

LOG.info("Our Quorum: " + zkw.getQuorum());
List<TableCFs> replicatedTableCFs = admin.listReplicatedTableCFs();
if (replicatedTableCFs.isEmpty()) {

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

@Before
public void setupBasicMocks() throws IOException, ServiceException {
 rs = Mockito.mock(HRegionServer.class);
 rpcServices = Mockito.mock(RSRpcServices.class);
 rpcServer = Mockito.mock(RpcServerInterface.class);
 Mockito.doReturn(HBaseConfiguration.create())
  .when(rs).getConfiguration();
 Mockito.doReturn(rpcServices).when(rs).getRSRpcServices();
 Mockito.doReturn(rpcServer).when(rs).getRpcServer();
 Mockito.doReturn(fakeResponse).when(rpcServices).getServerInfo(
  (RpcController)Mockito.any(), (GetServerInfoRequest)Mockito.any());
 // Fake ZKW
 ZKWatcher zkw = Mockito.mock(ZKWatcher.class);
 Mockito.doReturn("fakequorum").when(zkw).getQuorum();
 Mockito.doReturn(zkw).when(rs).getZooKeeper();
 // Fake BlockCache
 LOG.warn("The " + HConstants.HFILE_BLOCK_CACHE_SIZE_KEY + " is set to 0");
 Mockito.doReturn(Optional.empty()).when(rs).getBlockCache();
 // 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();
 Mockito.doReturn(rms).when(rs).getRegionServerMetrics();
 MetricsHBaseServer ms = Mockito.mock(MetricsHBaseServer.class);
 Mockito.doReturn(new MetricsHBaseServerWrapperStub()).when(ms).getHBaseServerWrapper();
 Mockito.doReturn(ms).when(rpcServer).getMetrics();
}

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

Mockito.doReturn("fakequorum").when(zkw).getQuorum();
Mockito.doReturn(zkw).when(master).getZooKeeper();

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

org.jamon.escaping.Escaping.HTML.write(org.jamon.emit.StandardEmitter.valueOf(regionServer.getZooKeeper().getQuorum()), jamonWriter);

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

rpc.setClusterKey(zkw.getQuorum());
String peerNode = zkStorageUtil.getPeerNode(peerId);
ZKUtil.createWithParents(zkw, peerNode, ReplicationPeerConfigUtil.toByteArray(rpc));
rpc.setClusterKey(zkw.getQuorum());
peerNode = zkStorageUtil.getPeerNode(peerId);
ZKUtil.createWithParents(zkw, peerNode, ReplicationPeerConfigUtil.toByteArray(rpc));
rpc.setClusterKey(zkw.getQuorum());
peerNode = zkStorageUtil.getPeerNode(peerId);
ZKUtil.createWithParents(zkw, peerNode, ReplicationPeerConfigUtil.toByteArray(rpc));
rpc.setClusterKey(zkw.getQuorum());
peerNode = zkStorageUtil.getPeerNode(peerId);
ZKUtil.createWithParents(zkw, peerNode, ReplicationPeerConfigUtil.toByteArray(rpc));

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

@Test
public void testDefaultMasterMetrics() throws Exception {
 MetricsMasterSource masterSource = master.getMasterMetrics().getMetricsSource();
 boolean tablesOnMaster = LoadBalancer.isTablesOnMaster(TEST_UTIL.getConfiguration());
 metricsHelper.assertGauge("numRegionServers", 1 + (tablesOnMaster ? 1 : 0), masterSource);
 metricsHelper.assertGauge("averageLoad", 1, masterSource);
 metricsHelper.assertGauge("numDeadRegionServers", 0, masterSource);
 metricsHelper.assertGauge("masterStartTime", master.getMasterStartTime(), masterSource);
 metricsHelper.assertGauge("masterActiveTime", master.getMasterActiveTime(), masterSource);
 metricsHelper.assertTag("isActiveMaster", "true", masterSource);
 metricsHelper.assertTag("serverName", master.getServerName().toString(), masterSource);
 metricsHelper.assertTag("clusterId", master.getClusterId(), masterSource);
 metricsHelper.assertTag("zookeeperQuorum", master.getZooKeeper().getQuorum(), masterSource);
}

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

private static void resetAcls(final Configuration conf, boolean eraseAcls)
  throws Exception {
 ZKWatcher zkw = new ZKWatcher(conf, "ZKAclReset", null);
 try {
  LOG.info((eraseAcls ? "Erase" : "Set") + " HBase ACLs for " +
       zkw.getQuorum() + " " + zkw.getZNodePaths().baseZNode);
  resetAcls(zkw, zkw.getZNodePaths().baseZNode, eraseAcls);
 } finally {
  zkw.close();
 }
}

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

String[] servers = zkw.getQuorum().split(",");
for (String server : servers) {
 sb.append("\n ").append(server);

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

Mockito.doReturn("fakequorum").when(zkw).getQuorum();
Mockito.doReturn(zkw).when(rs).getZooKeeper();

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

Mockito.doReturn("fakequorum").when(zkw).getQuorum();
Mockito.doReturn(zkw).when(master).getZooKeeper();

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

rpc.setClusterKey(zkw.getQuorum());
String peerNode = zkStorageUtil.getPeerNode(peerId);
ZKUtil.createWithParents(zkw, peerNode, ReplicationPeerConfigUtil.toByteArray(rpc));
rpc.setClusterKey(zkw.getQuorum());
peerNode = zkStorageUtil.getPeerNode(peerId);
ZKUtil.createWithParents(zkw, peerNode, ReplicationPeerConfigUtil.toByteArray(rpc));
rpc.setClusterKey(zkw.getQuorum());
peerNode = zkStorageUtil.getPeerNode(peerId);
ZKUtil.createWithParents(zkw, peerNode, ReplicationPeerConfigUtil.toByteArray(rpc));
rpc.setClusterKey(zkw.getQuorum());
peerNode = zkStorageUtil.getPeerNode(peerId);
ZKUtil.createWithParents(zkw, peerNode, ReplicationPeerConfigUtil.toByteArray(rpc));

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

@Test
public void testDefaultMasterMetrics() throws Exception {
 MetricsMasterSource masterSource = master.getMasterMetrics().getMetricsSource();
 boolean tablesOnMaster = LoadBalancer.isTablesOnMaster(TEST_UTIL.getConfiguration());
 metricsHelper.assertGauge( "numRegionServers",1 + (tablesOnMaster? 1: 0), masterSource);
 metricsHelper.assertGauge( "averageLoad", 1 + (tablesOnMaster? 0: 1), masterSource);
 metricsHelper.assertGauge( "numDeadRegionServers", 0, masterSource);
 metricsHelper.assertGauge("masterStartTime", master.getMasterStartTime(), masterSource);
 metricsHelper.assertGauge("masterActiveTime", master.getMasterActiveTime(), masterSource);
 metricsHelper.assertTag("isActiveMaster", "true", masterSource);
 metricsHelper.assertTag("serverName", master.getServerName().toString(), masterSource);
 metricsHelper.assertTag("clusterId", master.getClusterId(), masterSource);
 metricsHelper.assertTag("zookeeperQuorum", master.getZooKeeper().getQuorum(), masterSource);
}

内容来源于网络，如有侵权，请联系作者删除！

ZKWatcher

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com