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