org.apache.hadoop.hbase.zookeeper.ZNodePaths.getZNodeForReplica()方法的使用及代码示例-6ren

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

转载作者：知者更新时间：2024-03-15 08:34:49

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

ZNodePaths.getZNodeForReplica介绍

[英]Get the znode string corresponding to a replicaId
[中]获取与replicaId对应的znode字符串

代码示例

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

public static void deleteMetaLocation(ZKWatcher zookeeper, int replicaId)
 throws KeeperException {
 if (replicaId == RegionInfo.DEFAULT_REPLICA_ID) {
  LOG.info("Deleting hbase:meta region location in ZooKeeper");
 } else {
  LOG.info("Deleting hbase:meta for " + replicaId + " region location in ZooKeeper");
 }
 try {
  // Just delete the node.  Don't need any watches.
  ZKUtil.deleteNode(zookeeper, zookeeper.getZNodePaths().getZNodeForReplica(replicaId));
 } catch(KeeperException.NoNodeException nne) {
  // Has already been deleted
 }
}
/**

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

private void unassignMetaReplica(HbckInfo hi) throws IOException, InterruptedException,
KeeperException {
 undeployRegions(hi);
 ZKUtil.deleteNode(zkw, zkw.getZNodePaths().getZNodeForReplica(hi.metaEntry.getReplicaId()));
}

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

private static void waitUntilZnodeAvailable(int replicaId) throws Exception {
 String znode = util.getZooKeeperWatcher().getZNodePaths().getZNodeForReplica(replicaId);
 int i = 0;
 while (i < 1000) {
  if (ZKUtil.checkExists(util.getZooKeeperWatcher(), znode) == -1) {
   Thread.sleep(100);
   i++;
  } else break;
 }
 if (i == 1000) throw new IOException("znode for meta replica " + replicaId + " not available");
}

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

try {
 ZKUtil.setData(zookeeper,
   zookeeper.getZNodePaths().getZNodeForReplica(replicaId), data);
} catch(KeeperException.NoNodeException nne) {
 if (replicaId == RegionInfo.DEFAULT_REPLICA_ID) {
    ", create it");
 ZKUtil.createAndWatch(zookeeper, zookeeper.getZNodePaths().getZNodeForReplica(replicaId),
     data);

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

private void unassignExcessMetaReplica(int numMetaReplicasConfigured) {
  final ZKWatcher zooKeeper = master.getZooKeeper();
  // unassign the unneeded replicas (for e.g., if the previous master was configured
  // with a replication of 3 and now it is 2, we need to unassign the 1 unneeded replica)
  try {
   List<String> metaReplicaZnodes = zooKeeper.getMetaReplicaNodes();
   for (String metaReplicaZnode : metaReplicaZnodes) {
    int replicaId = zooKeeper.getZNodePaths().getMetaReplicaIdFromZnode(metaReplicaZnode);
    if (replicaId >= numMetaReplicasConfigured) {
     RegionState r = MetaTableLocator.getMetaRegionState(zooKeeper, replicaId);
     LOG.info("Closing excess replica of meta region " + r.getRegion());
     // send a close and wait for a max of 30 seconds
     ServerManager.closeRegionSilentlyAndWait(master.getClusterConnection(),
       r.getServerName(), r.getRegion(), 30000);
     ZKUtil.deleteNode(zooKeeper, zooKeeper.getZNodePaths().getZNodeForReplica(replicaId));
    }
   }
  } catch (Exception ex) {
   // ignore the exception since we don't want the master to be wedged due to potential
   // issues in the cleanup of the extra regions. We can do that cleanup via hbck or manually
   LOG.warn("Ignoring exception " + ex);
  }
 }
}

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

@Test
public void testZookeeperNodesForReplicas() throws Exception {
 // Checks all the znodes exist when meta's replicas are enabled
 ZKWatcher zkw = TEST_UTIL.getZooKeeperWatcher();
 Configuration conf = TEST_UTIL.getConfiguration();
 String baseZNode = conf.get(HConstants.ZOOKEEPER_ZNODE_PARENT,
   HConstants.DEFAULT_ZOOKEEPER_ZNODE_PARENT);
 String primaryMetaZnode = ZNodePaths.joinZNode(baseZNode,
   conf.get("zookeeper.znode.metaserver", "meta-region-server"));
 // check that the data in the znode is parseable (this would also mean the znode exists)
 byte[] data = ZKUtil.getData(zkw, primaryMetaZnode);
 ProtobufUtil.toServerName(data);
 for (int i = 1; i < 3; i++) {
  String secZnode = ZNodePaths.joinZNode(baseZNode,
    conf.get("zookeeper.znode.metaserver", "meta-region-server") + "-" + i);
  String str = zkw.getZNodePaths().getZNodeForReplica(i);
  assertTrue(str.equals(secZnode));
  // check that the data in the znode is parseable (this would also mean the znode exists)
  data = ZKUtil.getData(zkw, secZnode);
  ProtobufUtil.toServerName(data);
 }
}

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

ServerName serverName = null;
try {
 byte[] data = ZKUtil.getData(zkw, zkw.getZNodePaths().getZNodeForReplica(replicaId));
 if (data != null && data.length > 0 && ProtobufUtil.isPBMagicPrefix(data)) {
  try {

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

@Test
 public void testIsClientReadable() {
  ZNodePaths znodePaths = new ZNodePaths(HBaseConfiguration.create());
  assertTrue(znodePaths.isClientReadable(znodePaths.baseZNode));
  assertTrue(znodePaths.isClientReadable(znodePaths.getZNodeForReplica(0)));
  assertTrue(znodePaths.isClientReadable(znodePaths.masterAddressZNode));
  assertTrue(znodePaths.isClientReadable(znodePaths.clusterIdZNode));
  assertTrue(znodePaths.isClientReadable(znodePaths.tableZNode));
  assertTrue(znodePaths.isClientReadable(ZNodePaths.joinZNode(znodePaths.tableZNode, "foo")));
  assertTrue(znodePaths.isClientReadable(znodePaths.rsZNode));

  assertFalse(znodePaths.isClientReadable(znodePaths.tableLockZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.balancerZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.regionNormalizerZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.clusterStateZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.drainingZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.splitLogZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.backupMasterAddressesZNode));
 }
}

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

@Ignore @Test // The close silently doesn't work any more since HBASE-14614. Fix.
public void testHBaseFsckWithFewerMetaReplicaZnodes() throws Exception {
 ClusterConnection c = (ClusterConnection)ConnectionFactory.createConnection(
   TEST_UTIL.getConfiguration());
 RegionLocations rl = c.locateRegion(TableName.META_TABLE_NAME, HConstants.EMPTY_START_ROW,
   false, false);
 HBaseFsckRepair.closeRegionSilentlyAndWait(c,
   rl.getRegionLocation(2).getServerName(), rl.getRegionLocation(2).getRegionInfo());
 ZKWatcher zkw = TEST_UTIL.getZooKeeperWatcher();
 ZKUtil.deleteNode(zkw, zkw.getZNodePaths().getZNodeForReplica(2));
 // check that problem exists
 HBaseFsck hbck = doFsck(TEST_UTIL.getConfiguration(), false);
 assertErrors(hbck, new ERROR_CODE[]{ERROR_CODE.UNKNOWN,ERROR_CODE.NO_META_REGION});
 // fix the problem
 hbck = doFsck(TEST_UTIL.getConfiguration(), true);
 // run hbck again to make sure we don't see any errors
 hbck = doFsck(TEST_UTIL.getConfiguration(), false);
 assertErrors(hbck, new ERROR_CODE[]{});
}

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

public void deleteMetaLocation(ZKWatcher zookeeper, int replicaId)
 throws KeeperException {
 if (replicaId == RegionInfo.DEFAULT_REPLICA_ID) {
  LOG.info("Deleting hbase:meta region location in ZooKeeper");
 } else {
  LOG.info("Deleting hbase:meta for " + replicaId + " region location in ZooKeeper");
 }
 try {
  // Just delete the node.  Don't need any watches.
  ZKUtil.deleteNode(zookeeper, zookeeper.getZNodePaths().getZNodeForReplica(replicaId));
 } catch(KeeperException.NoNodeException nne) {
  // Has already been deleted
 }
}
/**

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

@Test
 public void testIsClientReadable() {
  ZNodePaths znodePaths = new ZNodePaths(HBaseConfiguration.create());
  assertTrue(znodePaths.isClientReadable(znodePaths.baseZNode));
  assertTrue(znodePaths.isClientReadable(znodePaths.getZNodeForReplica(0)));
  assertTrue(znodePaths.isClientReadable(znodePaths.masterAddressZNode));
  assertTrue(znodePaths.isClientReadable(znodePaths.clusterIdZNode));
  assertTrue(znodePaths.isClientReadable(znodePaths.tableZNode));
  assertTrue(znodePaths.isClientReadable(ZNodePaths.joinZNode(znodePaths.tableZNode, "foo")));
  assertTrue(znodePaths.isClientReadable(znodePaths.rsZNode));

  assertFalse(znodePaths.isClientReadable(znodePaths.tableLockZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.balancerZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.regionNormalizerZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.clusterStateZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.drainingZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.splitLogZNode));
  assertFalse(znodePaths.isClientReadable(znodePaths.backupMasterAddressesZNode));
 }
}

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

private static void waitUntilZnodeAvailable(int replicaId) throws Exception {
 String znode = util.getZooKeeperWatcher().getZNodePaths().getZNodeForReplica(replicaId);
 int i = 0;
 while (i < 1000) {
  if (ZKUtil.checkExists(util.getZooKeeperWatcher(), znode) == -1) {
   Thread.sleep(100);
   i++;
  } else break;
 }
 if (i == 1000) throw new IOException("znode for meta replica " + replicaId + " not available");
}

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

try {
 ZKUtil.setData(zookeeper,
   zookeeper.getZNodePaths().getZNodeForReplica(replicaId), data);
} catch(KeeperException.NoNodeException nne) {
 if (replicaId == RegionInfo.DEFAULT_REPLICA_ID) {
    ", create it");
 ZKUtil.createAndWatch(zookeeper, zookeeper.getZNodePaths().getZNodeForReplica(replicaId),
     data);

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

@Test
public void testZookeeperNodesForReplicas() throws Exception {
 // Checks all the znodes exist when meta's replicas are enabled
 ZKWatcher zkw = TEST_UTIL.getZooKeeperWatcher();
 Configuration conf = TEST_UTIL.getConfiguration();
 String baseZNode = conf.get(HConstants.ZOOKEEPER_ZNODE_PARENT,
   HConstants.DEFAULT_ZOOKEEPER_ZNODE_PARENT);
 String primaryMetaZnode = ZNodePaths.joinZNode(baseZNode,
   conf.get("zookeeper.znode.metaserver", "meta-region-server"));
 // check that the data in the znode is parseable (this would also mean the znode exists)
 byte[] data = ZKUtil.getData(zkw, primaryMetaZnode);
 ProtobufUtil.toServerName(data);
 for (int i = 1; i < 3; i++) {
  String secZnode = ZNodePaths.joinZNode(baseZNode,
    conf.get("zookeeper.znode.metaserver", "meta-region-server") + "-" + i);
  String str = zkw.getZNodePaths().getZNodeForReplica(i);
  assertTrue(str.equals(secZnode));
  // check that the data in the znode is parseable (this would also mean the znode exists)
  data = ZKUtil.getData(zkw, secZnode);
  ProtobufUtil.toServerName(data);
 }
}

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

ServerName serverName = null;
try {
 byte[] data = ZKUtil.getData(zkw, zkw.getZNodePaths().getZNodeForReplica(replicaId));
 if (data != null && data.length > 0 && ProtobufUtil.isPBMagicPrefix(data)) {
  try {

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

@Ignore @Test // The close silently doesn't work any more since HBASE-14614. Fix.
public void testHBaseFsckWithFewerMetaReplicaZnodes() throws Exception {
 ClusterConnection c = (ClusterConnection)ConnectionFactory.createConnection(
   TEST_UTIL.getConfiguration());
 RegionLocations rl = c.locateRegion(TableName.META_TABLE_NAME, HConstants.EMPTY_START_ROW,
   false, false);
 HBaseFsckRepair.closeRegionSilentlyAndWait(c,
   rl.getRegionLocation(2).getServerName(), rl.getRegionLocation(2).getRegionInfo());
 ZKWatcher zkw = TEST_UTIL.getZooKeeperWatcher();
 ZKUtil.deleteNode(zkw, zkw.getZNodePaths().getZNodeForReplica(2));
 // check that problem exists
 HBaseFsck hbck = doFsck(TEST_UTIL.getConfiguration(), false);
 assertErrors(hbck, new ERROR_CODE[]{ERROR_CODE.UNKNOWN,ERROR_CODE.NO_META_REGION});
 // fix the problem
 hbck = doFsck(TEST_UTIL.getConfiguration(), true);
 // run hbck again to make sure we don't see any errors
 hbck = doFsck(TEST_UTIL.getConfiguration(), false);
 assertErrors(hbck, new ERROR_CODE[]{});
}

文章推荐： pl.edu.icm.model.bwmeta.y.YCategoryRef类的使用及代码示例

schema.org - Schema.org、Goodrelations-vocabulary.org 和 Productontology.org 之间有什么关系？
Schema.org、Goodrelations-vocabulary.org 和 Productontology.org 之间有什么关系？ Schema.org 告知，“W3C schema.org
java - 为什么 org.ietf、org.omg、org.w3c 和 org.xml 是 POJO 的一部分？
大家好，我想知道包 org.ietf、org.omg、org.w3c 和 org 是如何实现的.xml 已进入 "official" Java classes ？例如，默认 JDK 不会包含 Apa
schema.org - DBpedia.org 本体与 Schema.org 本体
首先，我试图用来自 Schema.org 的属性定义数据库表，例如，例如，我有一个名为“JobPosting”的表，它或多或少具有与 http://schema.org/JobPosting 中定义的
java - 通过 org.w3c.dom.Element 对象作为 org.dom4j.Document 上的参数查找(将 org.w3c.dom.Element 转换为 org.dom4j.Element)
我有一个 org.w3c.dom.Document 被 org.dom4j.io.DOMReader 解析。我想通过 org.w3c.dom.Element 搜索 dom4j DOM 文档。比方说
java - 无法解析 - org.dom4j.DocumentException : org. dom4j.DocumentFactory 无法转换为 org.dom4j.DocumentFactory
我正在将我的应用程序部署到 Tomcat 6.0.20。应用程序使用 Hibernate 作为 Web 层的 ORM、Spring 和 JSF。我还从 main() 方法制作了简单的运行器来测试
deployment - 由 : org. dom4j.DocumentException 引起 : org. dom4j.DocumentFactory 无法转换为 org.dom4j.DocumentFactory
我有一个使用 hibernate > 4 的 gradle 项目。如果我在 Apache tomcat 中运行我的 war 文件，我不会收到任何错误。但是当我在 Wildfly 8.2 中部署它时，出
Android Studio : Could not find org. jacoco :org. jacoco.agent :org. gradle.testing.jacoco.plugins.JacocoPluginExtension_Decorated
我正在尝试将 JaCoCo 添加到我的 Android 以覆盖 Sonar Qube。但是在运行命令 ./gradlew jacocoTestReport 时，我收到以下错误。 Task :app:
org-mode - 在 org 模式下格式化日期
如何在 emacs 组织模式中格式化日期？例如，在下表中，我希望日期显示为“Aug 29”或“Wed, Aug 29”而不是“” #+ATTR_HTML: border="2" rules="all
org-mode - 在 org 文件中包含代码片段
我想使用 org 模式来写一本技术书籍。我正在寻找一种将外部文件中的现有代码插入到 babel 代码块中的方法，该代码块在导出为 pdf 时会提供很好的格式。例如 #+BEGIN_SRC pytho
schema.org - schema.org 中的产品类别？
用作引用:https://support.google.com/webmasters/answer/146750?hl=en 您会注意到在“产品”下有一个属性类别，此外页面下方还有一个示例: Too
schema.org - Schema.org 中的产品列表
我读了这个Google doc .它说我们不使用列表中的产品。那么对于产品列表(具有多页的类似产品的类别，如“鞋子”)，推荐使用哪种模式？我用这个: { "@context": "htt
schema.org - schema.org 数据集和维基数据之间是否存在映射？
我目前在做DBpedia数据集，想通过wikidata实现schema.org和DBpedia的映射。因此我想知道 schema.org 和 wikidata 之间是否存在任何映射。最佳答案我认为
org-mode - org-mode 表内的代码块
我爱org-tables ，我用它们来记录各种事情。我现在正在为 Nix 记录一些单行代码(在阅读了 Domen Kožar 的 excellent guide 后，在 this year's Eur
schema.org - schema.org 中的多个作者或贡献者
如果看一下 Movie在 schema.org 中输入，actor 和 actors 属性都是允许的(actor 取代 actors)。但是 author 和 contributor 属性没有等效项。
schema.org - Schema.org 中的多家餐厅
我们有一些餐厅有多个地点或分支机构。我想包含正确的 Schema.org 标记，但找不到任何允许列出多个餐厅的内容。每家餐厅都有自己的地址、电子邮件、电话和营业时间，甚至可能是“分店名称”。两个分
schema.org - Schema.org 的多个综合评级
我在一个页面中有多个综合评分片段。有没有办法让其中之一成为默认值？将显示在搜索引擎结果中的那个？谢谢大家! 更新:该网页本质上是品牌的页面。它包含品牌评论的总评分及其产品列表(每个产品的总评分)。
java - org.apache.maven.archiver.MavenArchiver.getManifest(org.apache.maven.project.MavenProject，org.apache.maven.archiver.MavenArchiveConfiguration)
我提到了一些相关的职位，但并没有解决我的问题。因为我正在使用maven-jar-plugin-2.4 jar。我正在使用JBoss Developer Studio 7.1.1 GA IDE，并且正
schema.org - 个人网站是否应该将根页面标记为 schema.org 'Person' ？
网站的根页面(即 http://example.com/ )的特殊之处在于它是默认的着陆页。它可能包含许多不同的对象类型。它可能被认为是一个网站，或者一个博客等... 但它是否也应该被标记为给定对象
org-mode - 如何隐藏一些文本不被 org-publish-* 函数发布？
我想将一些文本放入一个 org 文件中，当我将内容导出到其中一种目标类型(在本例中为 HTML)时，该文件不会发布。有什么方法可以实现这个目标吗？最佳答案您可能想要使用 :noexport: 标签
org-mode - 在 org-mode 的编号列表中的步骤之间移动
org-mode 是否有一个键绑定(bind)可以在编号/项目符号列表项之间移动，就像您可以对标题一样？喜欢的功能: org-forward-heading-same-level 大纲下一个可见标题

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城