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

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

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

ZKConfig.getZKQuorumServersString介绍

[英]Return the ZK Quorum servers string given zk properties returned by makeZKProps
[中]根据makeZKProps返回的ZK属性，返回ZK仲裁服务器字符串

代码示例

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

public String parse(final Configuration c) {
 return ZKConfig.getZKQuorumServersString(c);
}

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

/**
 * Creates a new connection to ZooKeeper, pulling settings and ensemble config
 * from the specified configuration object using methods from {@link ZKConfig}.
 *
 * Sets the connection status monitoring watcher to the specified watcher.
 *
 * @param conf configuration to pull ensemble and other settings from
 * @param watcher watcher to monitor connection changes
 * @return connection to zookeeper
 * @throws IOException if unable to connect to zk or config problem
 */
public static RecoverableZooKeeper connect(Configuration conf, Watcher watcher)
 throws IOException {
 String ensemble = ZKConfig.getZKQuorumServersString(conf);
 return connect(conf, ensemble, watcher);
}

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

String parentZNode = conf.get(HConstants.ZOOKEEPER_ZNODE_PARENT,
  HConstants.DEFAULT_ZOOKEEPER_ZNODE_PARENT);
ZooKeeper zk = new ZooKeeper(ZKConfig.getZKQuorumServersString(conf),
  conf.getInt(HConstants.ZK_SESSION_TIMEOUT,
  HConstants.DEFAULT_ZK_SESSION_TIMEOUT), EmptyWatcher.instance);

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

protected ZookeeperMonitor(Connection connection, String[] monitorTargets, boolean useRegExp,
  Sink sink, ExecutorService executor, boolean treatFailureAsError, long allowedFailures)  {
 super(connection, monitorTargets, useRegExp,
   sink, executor, treatFailureAsError, allowedFailures);
 Configuration configuration = connection.getConfiguration();
 znode =
   configuration.get(ZOOKEEPER_ZNODE_PARENT,
     DEFAULT_ZOOKEEPER_ZNODE_PARENT);
 timeout = configuration
   .getInt(HConstants.ZK_SESSION_TIMEOUT, HConstants.DEFAULT_ZK_SESSION_TIMEOUT);
 ConnectStringParser parser =
   new ConnectStringParser(ZKConfig.getZKQuorumServersString(configuration));
 hosts = Lists.newArrayList();
 for (InetSocketAddress server : parser.getServerAddresses()) {
  hosts.add(server.toString());
 }
 if (allowedFailures > (hosts.size() - 1) / 2) {
  LOG.warn("Confirm allowable number of failed ZooKeeper nodes, as quorum will " +
          "already be lost. Setting of {} failures is unexpected for {} ensemble size.",
      allowedFailures, hosts.size());
 }
}

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

public ReadOnlyZKClient(Configuration conf) {
 // We might use a different ZK for client access
 String clientZkQuorumServers = ZKConfig.getClientZKQuorumServersString(conf);
 if (clientZkQuorumServers != null) {
  this.connectString = clientZkQuorumServers;
 } else {
  this.connectString = ZKConfig.getZKQuorumServersString(conf);
 }
 this.sessionTimeoutMs = conf.getInt(ZK_SESSION_TIMEOUT, DEFAULT_ZK_SESSION_TIMEOUT);
 this.maxRetries = conf.getInt(RECOVERY_RETRY, DEFAULT_RECOVERY_RETRY);
 this.retryIntervalMs =
   conf.getInt(RECOVERY_RETRY_INTERVAL_MILLIS, DEFAULT_RECOVERY_RETRY_INTERVAL_MILLIS);
 this.keepAliveTimeMs = conf.getInt(KEEPALIVE_MILLIS, DEFAULT_KEEPALIVE_MILLIS);
 LOG.debug(
  "Connect {} to {} with session timeout={}ms, retries {}, " +
   "retry interval {}ms, keepAlive={}ms",
  getId(), connectString, sessionTimeoutMs, maxRetries, retryIntervalMs, keepAliveTimeMs);
 Threads.setDaemonThreadRunning(new Thread(this::run),
  "ReadOnlyZKClient-" + connectString + "@" + getId());
}

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

if (clientZK) {
 String clientZkQuorumServers = ZKConfig.getClientZKQuorumServersString(conf);
 String serverZkQuorumServers = ZKConfig.getZKQuorumServersString(conf);
 if (clientZkQuorumServers != null) {
  if (clientZkQuorumServers.equals(serverZkQuorumServers)) {
 this.quorum = ZKConfig.getZKQuorumServersString(conf);

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

@Test
 public void testGetZKQuorumServersString() {
  Configuration config = new Configuration(TEST_UTIL.getConfiguration());
  config.setInt(HConstants.ZOOKEEPER_CLIENT_PORT, 8888);
  config.set(HConstants.ZOOKEEPER_QUORUM, "foo:1234,bar:5678,baz,qux:9012");

  String s = ZKConfig.getZKQuorumServersString(config);
  assertEquals("foo:1234,bar:5678,baz:8888,qux:9012", s);
 }
}

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

conf = HBaseConfiguration.create();
zkQuorum = ZKConfig.getZKQuorumServersString(conf);
zkBaseDir = conf.get(HConstants.ZOOKEEPER_ZNODE_PARENT,
  HConstants.DEFAULT_ZOOKEEPER_ZNODE_PARENT);

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

throws Exception {
Configuration c = new Configuration(this.conf);
String quorumServers = ZKConfig.getZKQuorumServersString(c);
ZooKeeper zk = nodeZK.getRecoverableZooKeeper().getZooKeeper();
byte[] password = zk.getSessionPasswd();

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

@Test
public void testSetDataVersionMismatchInLoop() throws Exception {
 String znode = "/hbase/splitWAL/9af7cfc9b15910a0b3d714bf40a3248f";
 Configuration conf = TEST_UTIL.getConfiguration();
 ZKWatcher zkw = new ZKWatcher(conf, "testSetDataVersionMismatchInLoop",
   abortable, true);
 String ensemble = ZKConfig.getZKQuorumServersString(conf);
 RecoverableZooKeeper rzk = ZKUtil.connect(conf, ensemble, zkw);
 rzk.create(znode, new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
 rzk.setData(znode, "OPENING".getBytes(), 0);
 Field zkField = RecoverableZooKeeper.class.getDeclaredField("zk");
 zkField.setAccessible(true);
 int timeout = conf.getInt(HConstants.ZK_SESSION_TIMEOUT, HConstants.DEFAULT_ZK_SESSION_TIMEOUT);
 ZookeeperStub zkStub = new ZookeeperStub(ensemble, timeout, zkw);
 zkStub.setThrowExceptionInNumOperations(1);
 zkField.set(rzk, zkStub);
 byte[] opened = "OPENED".getBytes();
 rzk.setData(znode, opened, 1);
 byte[] data = rzk.getData(znode, false, new Stat());
 assertTrue(Bytes.equals(opened, data));
}

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

String quorumServers = ZKConfig.getZKQuorumServersString(c);
int sessionTimeout = 5 * 1000; // 5 seconds
ZooKeeper zk = new ZooKeeper(quorumServers, sessionTimeout, EmptyWatcher.instance);

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

public ReadOnlyZKClient(Configuration conf) {
 // We might use a different ZK for client access
 String clientZkQuorumServers = ZKConfig.getClientZKQuorumServersString(conf);
 if (clientZkQuorumServers != null) {
  this.connectString = clientZkQuorumServers;
 } else {
  this.connectString = ZKConfig.getZKQuorumServersString(conf);
 }
 this.sessionTimeoutMs = conf.getInt(ZK_SESSION_TIMEOUT, DEFAULT_ZK_SESSION_TIMEOUT);
 this.maxRetries = conf.getInt(RECOVERY_RETRY, DEFAULT_RECOVERY_RETRY);
 this.retryIntervalMs =
   conf.getInt(RECOVERY_RETRY_INTERVAL_MILLIS, DEFAULT_RECOVERY_RETRY_INTERVAL_MILLIS);
 this.keepAliveTimeMs = conf.getInt(KEEPALIVE_MILLIS, DEFAULT_KEEPALIVE_MILLIS);
 LOG.debug(
  "Connect {} to {} with session timeout={}ms, retries {}, " +
   "retry interval {}ms, keepAlive={}ms",
  getId(), connectString, sessionTimeoutMs, maxRetries, retryIntervalMs, keepAliveTimeMs);
 Threads.setDaemonThreadRunning(new Thread(this::run),
  "ReadOnlyZKClient-" + connectString + "@" + getId());
}

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

getConnectedZooKeeper(ZKConfig.getZKQuorumServersString(TEST_UTIL.getConfiguration()),
  60000);

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

private void ensureNamespaceDropped(String schemaName, long mutationTime) throws SQLException {
  SQLException sqlE = null;
  try (Admin admin = getAdmin()) {
    final String quorum = ZKConfig.getZKQuorumServersString(config);
    final String znode = this.props.get(HConstants.ZOOKEEPER_ZNODE_PARENT);
    logger.debug("Found quorum: " + quorum + ":" + znode);
    boolean nameSpaceExists = true;
    try {
      admin.getNamespaceDescriptor(schemaName);
    } catch (org.apache.hadoop.hbase.NamespaceNotFoundException e) {
      nameSpaceExists = false;
    }
    if (nameSpaceExists) {
      admin.deleteNamespace(schemaName);
    }
  } catch (IOException e) {
    sqlE = ServerUtil.parseServerException(e);
  } finally {
    if (sqlE != null) { throw sqlE; }
  }
}

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

public String parse(final Configuration c) {
 return ZKConfig.getZKQuorumServersString(c);
}

代码示例来源：origin: forcedotcom/phoenix

boolean tableExist = true;
try {
  System.out.println("Found quorum: " + ZKConfig.getZKQuorumServersString(config));
  admin = new HBaseAdmin(config);
  try {

代码示例来源：origin: co.cask.hbase/hbase

/**
  * Return the ZK Quorum servers string given the specified configuration.
  * @param conf
  * @return Quorum servers
  */
 public static String getZKQuorumServersString(Configuration conf) {
  return getZKQuorumServersString(makeZKProps(conf));
 }
}

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

boolean tableExist = true;
try (Admin admin = getAdmin()) {
  final String quorum = ZKConfig.getZKQuorumServersString(config);
  final String znode = this.getProps().get(HConstants.ZOOKEEPER_ZNODE_PARENT);
  logger.debug("Found quorum: " + quorum + ":" + znode);

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

@Test
 public void testGetZKQuorumServersString() {
  Configuration config = new Configuration(TEST_UTIL.getConfiguration());
  config.setInt(HConstants.ZOOKEEPER_CLIENT_PORT, 8888);
  config.set(HConstants.ZOOKEEPER_QUORUM, "foo:1234,bar:5678,baz,qux:9012");

  String s = ZKConfig.getZKQuorumServersString(config);
  assertEquals("foo:1234,bar:5678,baz:8888,qux:9012", s);
 }
}

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

@Test
 public void testGetZKQuorumServersString() {
  Configuration config = new Configuration(TEST_UTIL.getConfiguration());
  config.setInt(HConstants.ZOOKEEPER_CLIENT_PORT, 8888);
  config.set(HConstants.ZOOKEEPER_QUORUM, "foo:1234,bar:5678,baz,qux:9012");

  String s = ZKConfig.getZKQuorumServersString(config);
  assertEquals("foo:1234,bar:5678,baz:8888,qux:9012", s);
 }
}

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

ZKConfig

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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