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

ZooStore介绍

暂无

代码示例

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

public ZooTabletStateStore(ServerContext context) {
 store = new ZooStore(context);
}

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

@Override
public byte[] get(String path) throws DistributedStoreException {
 try {
  return cache.get(relative(path));
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

watchers.add(new TabletGroupWatcher(this, new ZooTabletStateStore(new ZooStore(context)),
  watchers.get(1)) {
 @Override

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

@Override
public List<String> getChildren(String path) throws DistributedStoreException {
 try {
  return cache.getChildren(relative(path));
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

public ZooTabletStateStore() throws DistributedStoreException {
 try {
  store = new ZooStore();
 } catch (IOException ex) {
  throw new DistributedStoreException(ex);
 }
}

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

@Override
public void put(String path, byte[] bs) throws DistributedStoreException {
 try {
  path = relative(path);
  context.getZooReaderWriter().putPersistentData(path, bs, NodeExistsPolicy.OVERWRITE);
  cache.clear();
  log.debug("Wrote {} to {}", new String(bs, UTF_8), path);
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

public ZooTabletStateStore() throws DistributedStoreException {
 try {
  store = new ZooStore();
 } catch (IOException ex) {
  throw new DistributedStoreException(ex);
 }
}

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

@Override
 public void remove(String path) throws DistributedStoreException {
  try {
   log.debug("Removing {}", path);
   path = relative(path);
   IZooReaderWriter zoo = context.getZooReaderWriter();
   if (zoo.exists(path))
    zoo.recursiveDelete(path, NodeMissingPolicy.SKIP);
   cache.clear();
  } catch (Exception ex) {
   throw new DistributedStoreException(ex);
  }
 }
}

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

final TabletStateStore stores[] = {new ZooTabletStateStore(new ZooStore(zroot)),

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

@Override
public List<String> getChildren(String path) throws DistributedStoreException {
 try {
  return cache.getChildren(relative(path));
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

watchers.add(new TabletGroupWatcher(this, new ZooTabletStateStore(new ZooStore(zroot)),
  watchers.get(1)) {
 @Override

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

@Override
public byte[] get(String path) throws DistributedStoreException {
 try {
  return cache.get(relative(path));
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

@Override
public byte[] get(String path) throws DistributedStoreException {
 try {
  return cache.get(relative(path));
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

@Override
public List<String> getChildren(String path) throws DistributedStoreException {
 try {
  return cache.getChildren(relative(path));
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

@Override
public void put(String path, byte[] bs) throws DistributedStoreException {
 try {
  path = relative(path);
  ZooReaderWriter.getInstance().putPersistentData(path, bs, NodeExistsPolicy.OVERWRITE);
  cache.clear();
  log.debug("Wrote " + new String(bs, UTF_8) + " to " + path);
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

@Override
public void put(String path, byte[] bs) throws DistributedStoreException {
 try {
  path = relative(path);
  ZooReaderWriter.getInstance().putPersistentData(path, bs, NodeExistsPolicy.OVERWRITE);
  cache.clear();
  log.debug("Wrote " + new String(bs, UTF_8) + " to " + path);
 } catch (Exception ex) {
  throw new DistributedStoreException(ex);
 }
}

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

@Override
 public void remove(String path) throws DistributedStoreException {
  try {
   log.debug("Removing " + path);
   path = relative(path);
   IZooReaderWriter zoo = ZooReaderWriter.getInstance();
   if (zoo.exists(path))
    zoo.recursiveDelete(path, NodeMissingPolicy.SKIP);
   cache.clear();
  } catch (Exception ex) {
   throw new DistributedStoreException(ex);
  }
 }
}

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

@Override
 public void remove(String path) throws DistributedStoreException {
  try {
   log.debug("Removing " + path);
   path = relative(path);
   IZooReaderWriter zoo = ZooReaderWriter.getInstance();
   if (zoo.exists(path))
    zoo.recursiveDelete(path, NodeMissingPolicy.SKIP);
   cache.clear();
  } catch (Exception ex) {
   throw new DistributedStoreException(ex);
  }
 }
}