org.apache.hadoop.hbase.client.ZKAsyncRegistry类的使用及代码示例

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

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

ZKAsyncRegistry介绍

[英]Fetch the registry data from zookeeper.
[中]从zookeeper获取注册表数据。

代码示例

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

znodePaths.metaReplicaZNodes.forEach((replicaId, path) -> {
 if (replicaId == DEFAULT_REPLICA_ID) {
  getAndConvert(path, ZKAsyncRegistry::getMetaProto).whenComplete((proto, error) -> {
   if (error != null) {
    future.completeExceptionally(error);
   Pair<RegionState.State, ServerName> stateAndServerName = getStateAndServerName(proto);
   if (stateAndServerName.getFirst() != RegionState.State.OPEN) {
    future.completeExceptionally(
     new HRegionLocation(getRegionInfoForDefaultReplica(FIRST_META_REGIONINFO),
       stateAndServerName.getSecond());
   tryComplete(remaining, locs, future);
  });
 } else {
  getAndConvert(path, ZKAsyncRegistry::getMetaProto).whenComplete((proto, error) -> {
   if (future.isDone()) {
    return;
    locs[replicaId] = null;
   } else {
    Pair<RegionState.State, ServerName> stateAndServerName = getStateAndServerName(proto);
    if (stateAndServerName.getFirst() != RegionState.State.OPEN) {
     LOG.warn("Meta region for replica " + replicaId + " is in state " +
   tryComplete(remaining, locs, future);
  });

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

@Test
 public void testIndependentZKConnections() throws IOException {
  try (ReadOnlyZKClient zk1 = REGISTRY.getZKClient()) {
   Configuration otherConf = new Configuration(TEST_UTIL.getConfiguration());
   otherConf.set(HConstants.ZOOKEEPER_QUORUM, "127.0.0.1");
   try (ZKAsyncRegistry otherRegistry = new ZKAsyncRegistry(otherConf)) {
    ReadOnlyZKClient zk2 = otherRegistry.getZKClient();
    assertNotSame("Using a different configuration / quorum should result in different " +
     "backing zk connection.", zk1, zk2);
    assertNotEquals(
     "Using a different configrution / quorum should be reflected in the zk connection.",
     zk1.getConnectString(), zk2.getConnectString());
   }
  } finally {
   LOG.info("DONE!");
  }
 }
}

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

@Test
public void test() throws InterruptedException, ExecutionException, IOException {
 LOG.info("STARTED TEST");
 String clusterId = REGISTRY.getClusterId().get();
 String expectedClusterId = TEST_UTIL.getHBaseCluster().getMaster().getClusterId();
 assertEquals("Expected " + expectedClusterId + ", found=" + clusterId, expectedClusterId,
  clusterId);
 assertEquals(TEST_UTIL.getHBaseCluster().getClusterMetrics().getLiveServerMetrics().size(),
  REGISTRY.getCurrentNrHRS().get().intValue());
 assertEquals(TEST_UTIL.getHBaseCluster().getMaster().getServerName(),
  REGISTRY.getMasterAddress().get());
 assertEquals(-1, REGISTRY.getMasterInfoPort().get().intValue());
 RegionReplicaTestHelper.waitUntilAllMetaReplicasHavingRegionLocation(REGISTRY, 3);
 RegionLocations locs = REGISTRY.getMetaRegionLocation().get();
 assertEquals(3, locs.getRegionLocations().length);
 IntStream.range(0, 3).forEach(i -> {
  HRegionLocation loc = locs.getRegionLocation(i);
  assertNotNull("Replica " + i + " doesn't have location", loc);
  assertEquals(TableName.META_TABLE_NAME, loc.getRegion().getTable());
  assertEquals(i, loc.getRegion().getReplicaId());
 });
}

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

@Override
public CompletableFuture<String> getClusterId() {
 return getAndConvert(znodePaths.clusterIdZNode, ZKAsyncRegistry::getClusterId);
}

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

@BeforeClass
public static void setUp() throws Exception {
 TEST_UTIL.getConfiguration().setInt(META_REPLICAS_NUM, 3);
 TEST_UTIL.startMiniCluster(3);
 REGISTRY = new ZKAsyncRegistry(TEST_UTIL.getConfiguration());
}

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

@Override
 public boolean evaluate() throws IOException {
  AtomicBoolean ready = new AtomicBoolean(true);
  try {
   RegionLocations locs = REGISTRY.getMetaRegionLocation().get();
   assertEquals(3, locs.getRegionLocations().length);
   IntStream.range(0, 3).forEach(i -> {
    HRegionLocation loc = locs.getRegionLocation(i);
    if (loc == null) {
     ready.set(false);
    }
   });
  } catch (Exception e) {
   ready.set(false);
  }
  return ready.get();
 }
});

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

@Test
public void test() throws InterruptedException, ExecutionException, IOException {
 LOG.info("STARTED TEST");
 String clusterId = REGISTRY.getClusterId().get();
 String expectedClusterId = TEST_UTIL.getHBaseCluster().getMaster().getClusterId();
 assertEquals("Expected " + expectedClusterId + ", found=" + clusterId,
   expectedClusterId, clusterId);
 assertEquals(TEST_UTIL.getHBaseCluster().getClusterMetrics().getLiveServerMetrics().size(),
  REGISTRY.getCurrentNrHRS().get().intValue());
 assertEquals(TEST_UTIL.getHBaseCluster().getMaster().getServerName(),
  REGISTRY.getMasterAddress().get());
 assertEquals(-1, REGISTRY.getMasterInfoPort().get().intValue());
 waitUntilAllReplicasHavingRegionLocation(TableName.META_TABLE_NAME);
 RegionLocations locs = REGISTRY.getMetaRegionLocation().get();
 assertEquals(3, locs.getRegionLocations().length);
 IntStream.range(0, 3).forEach(i -> {
  HRegionLocation loc = locs.getRegionLocation(i);
  assertNotNull("Replica " + i + " doesn't have location", loc);
  assertEquals(TableName.META_TABLE_NAME, loc.getRegion().getTable());
  assertEquals(i, loc.getRegion().getReplicaId());
 });
}

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

@Override
public CompletableFuture<Integer> getMasterInfoPort() {
 return getAndConvert(znodePaths.masterAddressZNode, ZKAsyncRegistry::getMasterProto)
   .thenApply(proto -> proto != null ? proto.getInfoPort() : 0);
}

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

@BeforeClass
public static void setUp() throws Exception {
 TEST_UTIL.getConfiguration().setInt(META_REPLICAS_NUM, 3);
 TEST_UTIL.startMiniCluster(3);
 REGISTRY = new ZKAsyncRegistry(TEST_UTIL.getConfiguration());
}

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

znodePaths.metaReplicaZNodes.forEach((replicaId, path) -> {
 if (replicaId == DEFAULT_REPLICA_ID) {
  getAndConvert(path, ZKAsyncRegistry::getMetaProto).whenComplete((proto, error) -> {
   if (error != null) {
    future.completeExceptionally(error);
   Pair<RegionState.State, ServerName> stateAndServerName = getStateAndServerName(proto);
   if (stateAndServerName.getFirst() != RegionState.State.OPEN) {
    future.completeExceptionally(
     new HRegionLocation(getRegionInfoForDefaultReplica(FIRST_META_REGIONINFO),
       stateAndServerName.getSecond());
   tryComplete(remaining, locs, future);
  });
 } else {
  getAndConvert(path, ZKAsyncRegistry::getMetaProto).whenComplete((proto, error) -> {
   if (future.isDone()) {
    return;
    locs[replicaId] = null;
   } else {
    Pair<RegionState.State, ServerName> stateAndServerName = getStateAndServerName(proto);
    if (stateAndServerName.getFirst() != RegionState.State.OPEN) {
     LOG.warn("Meta region for replica " + replicaId + " is in state " +
   tryComplete(remaining, locs, future);
  });

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

@Override
public CompletableFuture<ServerName> getMasterAddress() {
 return getAndConvert(znodePaths.masterAddressZNode, ZKAsyncRegistry::getMasterProto)
   .thenApply(proto -> {
    if (proto == null) {
     return null;
    }
    HBaseProtos.ServerName snProto = proto.getMaster();
    return ServerName.valueOf(snProto.getHostName(), snProto.getPort(),
     snProto.getStartCode());
   });
}

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

@Test
 public void testIndependentZKConnections() throws IOException {
  try (ReadOnlyZKClient zk1 = REGISTRY.getZKClient()) {
   Configuration otherConf = new Configuration(TEST_UTIL.getConfiguration());
   otherConf.set(HConstants.ZOOKEEPER_QUORUM, "127.0.0.1");
   try (ZKAsyncRegistry otherRegistry = new ZKAsyncRegistry(otherConf)) {
    ReadOnlyZKClient zk2 = otherRegistry.getZKClient();
    assertNotSame("Using a different configuration / quorum should result in different " +
     "backing zk connection.", zk1, zk2);
    assertNotEquals(
     "Using a different configrution / quorum should be reflected in the zk connection.",
     zk1.getConnectString(), zk2.getConnectString());
   }
  } finally {
   LOG.info("DONE!");
  }
 }
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

znodePaths.metaReplicaZNodes.forEach((replicaId, path) -> {
 if (replicaId == DEFAULT_REPLICA_ID) {
  getAndConvert(path, ZKAsyncRegistry::getMetaProto).whenComplete((proto, error) -> {
   if (error != null) {
    future.completeExceptionally(error);
   Pair<RegionState.State, ServerName> stateAndServerName = getStateAndServerName(proto);
   if (stateAndServerName.getFirst() != RegionState.State.OPEN) {
    future.completeExceptionally(
     new HRegionLocation(getRegionInfoForDefaultReplica(FIRST_META_REGIONINFO),
       stateAndServerName.getSecond());
   tryComplete(remaining, locs, future);
  });
 } else {
  getAndConvert(path, ZKAsyncRegistry::getMetaProto).whenComplete((proto, error) -> {
   if (future.isDone()) {
    return;
    locs[replicaId] = null;
   } else {
    Pair<RegionState.State, ServerName> stateAndServerName = getStateAndServerName(proto);
    if (stateAndServerName.getFirst() != RegionState.State.OPEN) {
     LOG.warn("Meta region for replica " + replicaId + " is in state " +
   tryComplete(remaining, locs, future);
  });

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

@Override
public CompletableFuture<String> getClusterId() {
 return getAndConvert(znodePaths.clusterIdZNode, ZKAsyncRegistry::getClusterId);
}

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

@Override
public CompletableFuture<Integer> getMasterInfoPort() {
 return getAndConvert(znodePaths.masterAddressZNode, ZKAsyncRegistry::getMasterProto)
   .thenApply(proto -> proto != null ? proto.getInfoPort() : 0);
}

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

@Override
public CompletableFuture<ServerName> getMasterAddress() {
 return getAndConvert(znodePaths.masterAddressZNode, ZKAsyncRegistry::getMasterProto)
   .thenApply(proto -> {
    if (proto == null) {
     return null;
    }
    HBaseProtos.ServerName snProto = proto.getMaster();
    return ServerName.valueOf(snProto.getHostName(), snProto.getPort(),
     snProto.getStartCode());
   });
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

@Override
public CompletableFuture<String> getClusterId() {
 return getAndConvert(znodePaths.clusterIdZNode, ZKAsyncRegistry::getClusterId);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

@Override
public CompletableFuture<Integer> getMasterInfoPort() {
 return getAndConvert(znodePaths.masterAddressZNode, ZKAsyncRegistry::getMasterProto)
   .thenApply(proto -> proto != null ? proto.getInfoPort() : 0);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

@Override
public CompletableFuture<ServerName> getMasterAddress() {
 return getAndConvert(znodePaths.masterAddressZNode, ZKAsyncRegistry::getMasterProto)
   .thenApply(proto -> {
    if (proto == null) {
     return null;
    }
    HBaseProtos.ServerName snProto = proto.getMaster();
    return ServerName.valueOf(snProto.getHostName(), snProto.getPort(),
     snProto.getStartCode());
   });
}

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

ZKAsyncRegistry

相关文章

    查看更多

    热门标签

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

    最新文章

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