com.ngdata.sep.util.zookeeper.ZkUtil类的使用及代码示例

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

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

ZkUtil介绍

[英]Various ZooKeeper utility methods.
[中]各种动物园管理员实用方法。

代码示例

代码示例来源：origin: com.ngdata/hbase-sep-impl-common

public static void createPath(final ZooKeeperItf zk, final String path)
    throws InterruptedException, KeeperException {
  createPath(zk, path, null);
}

代码示例来源：origin: NGDATA/hbase-indexer

private JettySolrRunner createServer() throws Exception {
  // create path on zookeeper for solr cloud
  ZooKeeperItf zk = ZkUtil.connect("localhost:" + zkClientPort, 10000);
  ZkUtil.createPath(zk, "/solr");
  zk.close();
  return new JettySolrRunner(solrHomeDir.toString(), "/solr", solrPort);
}

代码示例来源：origin: NGDATA/hbase-indexer

public static void main(String[] args) throws Exception {
  Configuration conf = HBaseConfiguration.create();
  conf.setBoolean("hbase.replication", true);
  ZooKeeperItf zk = ZkUtil.connect("localhost", 20000);
  SepModel sepModel = new SepModelImpl(zk, conf);
  final String subscriptionName = "logger";
  if (!sepModel.hasSubscription(subscriptionName)) {
    sepModel.addSubscriptionSilent(subscriptionName);
  }
  PayloadExtractor payloadExtractor = new BasePayloadExtractor(Bytes.toBytes("sep-user-demo"), Bytes.toBytes("info"),
      Bytes.toBytes("payload"));
  SepConsumer sepConsumer = new SepConsumer(subscriptionName, 0, new EventLogger(), 1, "localhost", zk, conf,
      payloadExtractor);
  sepConsumer.start();
  System.out.println("Started");
  while (true) {
    Thread.sleep(Long.MAX_VALUE);
  }
}

代码示例来源：origin: NGDATA/hbase-indexer

ZkUtil.deleteNode(zk, basePath + "/hbaseid");
  for (String child : zk.getChildren(basePath + "/rs", false)) {
    ZkUtil.deleteNode(zk, basePath + "/rs/" + child);
  ZkUtil.deleteNode(zk, basePath + "/rs");
  ZkUtil.deleteNode(zk, basePath);
} catch (InterruptedException ie) {
  Thread.currentThread().interrupt();

代码示例来源：origin: NGDATA/hbase-indexer

ZooKeeperItf zk = ZkUtil.connect(zkConnectString, 30000);
waitUntilReplicationDone(zk, options.valueOf(hbaseMasterPortOption));

代码示例来源：origin: com.ngdata/hbase-sep-impl-common

ZkUtil.deleteNode(zk, basePath + "/hbaseid");
  for (String child : zk.getChildren(basePath + "/rs", false)) {
    ZkUtil.deleteNode(zk, basePath + "/rs/" + child);
  ZkUtil.deleteNode(zk, basePath + "/rs");
  ZkUtil.deleteNode(zk, basePath);
} catch (InterruptedException ie) {
  Thread.currentThread().interrupt();

代码示例来源：origin: NGDATA/hbase-indexer

public static void createPath(final ZooKeeperItf zk, final String path)
    throws InterruptedException, KeeperException {
  createPath(zk, path, null);
}

代码示例来源：origin: com.ngdata/hbase-indexer-common

private JettySolrRunner createServer() throws Exception {
  // create path on zookeeper for solr cloud
  ZooKeeperItf zk = ZkUtil.connect("localhost:" + zkClientPort, 10000);
  ZkUtil.createPath(zk, "/solr");
  zk.close();
  return new JettySolrRunner(solrHomeDir.toString(), "/solr", solrPort);
}

代码示例来源：origin: com.ngdata/hbase-sep-tools

ZooKeeperItf zk = ZkUtil.connect(zkConnectString, 30000);
waitUntilReplicationDone(zk, options.valueOf(hbaseMasterPortOption), options.has(useSSL), options.valueOf(zookeeperZNodeParentOption));

代码示例来源：origin: NGDATA/hbase-indexer

public IndexerProcessRegistryImpl(ZooKeeperItf zk, Configuration conf) throws InterruptedException, KeeperException {
  this.zk = zk;
  this.zkBaseNode = conf.get(ConfKeys.ZK_ROOT_NODE) + "/indexerprocess";
  ZkUtil.createPath(zk, zkBaseNode);
}

代码示例来源：origin: NGDATA/hbase-indexer

ZooKeeperItf zk = ZkUtil.connect(zkConnectString, 30000);

代码示例来源：origin: com.ngdata/hbase-indexer-model

public IndexerProcessRegistryImpl(ZooKeeperItf zk, Configuration conf) throws InterruptedException, KeeperException {
  this.zk = zk;
  this.zkBaseNode = conf.get(ConfKeys.ZK_ROOT_NODE) + "/indexerprocess";
  ZkUtil.createPath(zk, zkBaseNode);
}

代码示例来源：origin: com.ngdata/hbase-sep-tools

ZooKeeperItf zk = ZkUtil.connect(zkConnectString, 30000);

代码示例来源：origin: NGDATA/hbase-indexer

public IndexerModelImpl(ZooKeeperItf zk, String zkRoot) throws InterruptedException, KeeperException {
  this.zk = zk;
  this.indexerCollectionPath = zkRoot + "/indexer";
  this.indexerCollectionPathSlash = indexerCollectionPath + "/";
  this.indexerTrashPath = zkRoot + "/indexer-trash";
  ZkUtil.createPath(zk, indexerCollectionPath);
  ZkUtil.createPath(zk, indexerTrashPath);
  zk.addDefaultWatcher(connectStateWatcher);
  indexerCacheRefresher.start();
  indexerCacheRefresher.waitUntilStarted();
}

代码示例来源：origin: com.ngdata/hbase-indexer-model

public IndexerModelImpl(ZooKeeperItf zk, String zkRoot) throws InterruptedException, KeeperException {
  this.zk = zk;
  this.indexerCollectionPath = zkRoot + "/indexer";
  this.indexerCollectionPathSlash = indexerCollectionPath + "/";
  this.indexerTrashPath = zkRoot + "/indexer-trash";
  ZkUtil.createPath(zk, indexerCollectionPath);
  ZkUtil.createPath(zk, indexerTrashPath);
  zk.addDefaultWatcher(connectStateWatcher);
  indexerCacheRefresher.start();
  indexerCacheRefresher.waitUntilStarted();
}

代码示例来源：origin: NGDATA/hbase-indexer

ZkUtil.createPath(zk, basePath + "/hbaseid", Bytes.toBytes(uuid.toString()));
ZkUtil.createPath(zk, basePath + "/rs");

代码示例来源：origin: com.ngdata/hbase-sep-impl-common

ZkUtil.createPath(zk, basePath + "/hbaseid", Bytes.toBytes(uuid.toString()));
ZkUtil.createPath(zk, basePath + "/rs");

代码示例来源：origin: NGDATA/hbase-indexer

private void proposeAsLeader() throws LeaderElectionSetupException, InterruptedException, KeeperException {
  ZkUtil.createPath(zk, electionPath);
  try {
    // In case of connection loss, a node might have been created for us (we do not know it). Therefore,
    // retrying upon connection loss is important, so that we can continue with watching the leaders.
    // Later on, we do not look at the name of the node we created here, but at the owner.
    zk.retryOperation(new ZooKeeperOperation<String>() {
      @Override
      public String execute() throws KeeperException, InterruptedException {
        return zk.create(electionPath + "/n_", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
      }
    });
  } catch (KeeperException e) {
    throw new LeaderElectionSetupException("Error creating leader election zookeeper node below " +
        electionPath, e);
  }
  watchLeaders();
}

代码示例来源：origin: com.ngdata/hbase-indexer-common

private void proposeAsLeader() throws LeaderElectionSetupException, InterruptedException, KeeperException {
  ZkUtil.createPath(zk, electionPath);
  try {
    // In case of connection loss, a node might have been created for us (we do not know it). Therefore,
    // retrying upon connection loss is important, so that we can continue with watching the leaders.
    // Later on, we do not look at the name of the node we created here, but at the owner.
    zk.retryOperation(new ZooKeeperOperation<String>() {
      @Override
      public String execute() throws KeeperException, InterruptedException {
        return zk.create(electionPath + "/n_", null, CreateMode.EPHEMERAL_SEQUENTIAL);
      }
    });
  } catch (KeeperException e) {
    throw new LeaderElectionSetupException("Error creating leader election zookeeper node below " +
        electionPath, e);
  }
  watchLeaders();
}

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

ZKUtil

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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