gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-13 13:01:32 26 4
gpt4 key购买 nike

本文整理了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());
   });
}

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com