个人中心
gpt4 book ai didi

org.apache.accumulo.server.zookeeper.ZooReaderWriter.getZooKeeper()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 21:52:03 27 4
gpt4 key购买 nike

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

ZooReaderWriter.getZooKeeper介绍

暂无

代码示例

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

public void visit(ZooReader zoo, String path) throws Exception {
  String newPath = path.replace(inst.getInstanceID(), newInstanceId);
  byte[] data = zoo.getData(path, null);
  List<ACL> acls = orig.getZooKeeper().getACL(path, new Stat());
  if (acls.containsAll(Ids.READ_ACL_UNSAFE)) {
   new_.putPersistentData(newPath, data, NodeExistsPolicy.FAIL);
  } else {
   // upgrade
   if (acls.containsAll(Ids.OPEN_ACL_UNSAFE)) {
    // make user nodes private, they contain the user's password
    String parts[] = path.split("/");
    if (parts[parts.length - 2].equals("users")) {
     new_.putPrivatePersistentData(newPath, data, NodeExistsPolicy.FAIL);
    } else {
     // everything else can have the readable acl
     new_.putPersistentData(newPath, data, NodeExistsPolicy.FAIL);
    }
   } else {
    new_.putPrivatePersistentData(newPath, data, NodeExistsPolicy.FAIL);
   }
  }
 }
});

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

@Override
 public void visit(ZooReader zoo, String path) throws Exception {
  String newPath = path.replace(inst.getInstanceID(), newInstanceId);
  byte[] data = zoo.getData(path, null);
  List<ACL> acls = orig.getZooKeeper().getACL(path, new Stat());
  if (acls.containsAll(Ids.READ_ACL_UNSAFE)) {
   new_.putPersistentData(newPath, data, NodeExistsPolicy.FAIL);
  } else {
   // upgrade
   if (acls.containsAll(Ids.OPEN_ACL_UNSAFE)) {
    // make user nodes private, they contain the user's password
    String parts[] = path.split("/");
    if (parts[parts.length - 2].equals("users")) {
     new_.putPrivatePersistentData(newPath, data, NodeExistsPolicy.FAIL);
    } else {
     // everything else can have the readable acl
     new_.putPersistentData(newPath, data, NodeExistsPolicy.FAIL);
    }
   } else {
    new_.putPrivatePersistentData(newPath, data, NodeExistsPolicy.FAIL);
   }
  }
 }
});

代码示例来源：origin: org.apache.accumulo/accumulo-tracer

public static void main(String[] args) throws Exception {
 final String app = "tracer";
 Accumulo.setupLogging(app);
 loginTracer(SiteConfiguration.getInstance());
 ServerOpts opts = new ServerOpts();
 opts.parseArgs(app, args);
 Instance instance = HdfsZooInstance.getInstance();
 ServerConfigurationFactory conf = new ServerConfigurationFactory(instance);
 VolumeManager fs = VolumeManagerImpl.get();
 MetricsSystemHelper.configure(TraceServer.class.getSimpleName());
 Accumulo.init(fs, conf, app);
 String hostname = opts.getAddress();
 TraceServer server = new TraceServer(conf, hostname);
 try {
  server.run();
 } finally {
  log.info("tracer stopping");
  ZooReaderWriter.getInstance().getZooKeeper().close();
 }
}

27 4 0
文章推荐： pl.edu.icm.model.bwmeta.y.YExportable类的使用及代码示例
文章推荐： org.apache.helix.manager.zk.ZkBaseDataAccessor.remove()方法的使用及代码示例
文章推荐： org.opendaylight.yangtools.yang.model.api.YangStmtMapping类的使用及代码示例
文章推荐： org.apache.accumulo.server.zookeeper.ZooReaderWriter类的使用及代码示例
知者
个人简介

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

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com