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

ZooSession介绍

暂无

代码示例

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

protected ZooKeeper getSession(String keepers, int timeout, String scheme, byte[] auth) {
 return ZooSession.getSession(keepers, timeout, scheme, auth);
}

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

public static synchronized ZooKeeper getSession(String zooKeepers, int timeout, String scheme,
  byte[] auth) {
 if (sessions == null)
  throw new ZooSessionShutdownException(
    "The Accumulo singleton that that tracks zookeeper session is disabled.  This is likely "
      + "caused by all AccumuloClients being closed or garbage collected.");
 String sessionKey = sessionKey(zooKeepers, timeout, scheme, auth);
 // a read-only session can use a session with authorizations, so cache a copy for it w/out auths
 String readOnlySessionKey = sessionKey(zooKeepers, timeout, null, null);
 ZooSessionInfo zsi = sessions.get(sessionKey);
 if (zsi != null && zsi.zooKeeper.getState() == States.CLOSED) {
  log.debug("Removing closed ZooKeeper session to {}", zooKeepers);
  if (auth != null && sessions.get(readOnlySessionKey) == zsi)
   sessions.remove(readOnlySessionKey);
  zsi = null;
  sessions.remove(sessionKey);
 }
 if (zsi == null) {
  ZooWatcher watcher = new ZooWatcher();
  log.debug("Connecting to {} with timeout {} with auth", zooKeepers, timeout);
  zsi = new ZooSessionInfo(connect(zooKeepers, timeout, scheme, auth, watcher));
  sessions.put(sessionKey, zsi);
  if (auth != null && !sessions.containsKey(readOnlySessionKey))
   sessions.put(readOnlySessionKey, zsi);
 }
 return zsi.zooKeeper;
}

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

/**
 * kills all threads created by internal Accumulo singleton resources. After this method is
 * called, no accumulo client will work in the current classloader.
 */
public static void shutdownNow() {
 ThriftTransportPool.getInstance().shutdown();
 ZooSession.shutdown();
 waitForZooKeeperClientThreads();
}

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

public static synchronized ZooKeeper getSession(String zooKeepers, int timeout, String scheme,
  byte[] auth) {
 if (sessions == null)
  throw new ZooSessionShutdownException();
 String sessionKey = sessionKey(zooKeepers, timeout, scheme, auth);
 // a read-only session can use a session with authorizations, so cache a copy for it w/out auths
 String readOnlySessionKey = sessionKey(zooKeepers, timeout, null, null);
 ZooSessionInfo zsi = sessions.get(sessionKey);
 if (zsi != null && zsi.zooKeeper.getState() == States.CLOSED) {
  log.debug("Removing closed ZooKeeper session to " + zooKeepers);
  if (auth != null && sessions.get(readOnlySessionKey) == zsi)
   sessions.remove(readOnlySessionKey);
  zsi = null;
  sessions.remove(sessionKey);
 }
 if (zsi == null) {
  ZooWatcher watcher = new ZooWatcher();
  log.debug("Connecting to " + zooKeepers + " with timeout " + timeout + " with auth");
  zsi = new ZooSessionInfo(connect(zooKeepers, timeout, scheme, auth, watcher), watcher);
  sessions.put(sessionKey, zsi);
  if (auth != null && !sessions.containsKey(readOnlySessionKey))
   sessions.put(readOnlySessionKey, zsi);
 }
 return zsi.zooKeeper;
}

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

protected static ZooKeeper getZooKeeper(String keepers, int timeout, String scheme, byte[] auth) {
 return ZooSession.getSession(keepers, timeout, scheme, auth);
}

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

protected static ZooKeeper getZooKeeper(String keepers, int timeout, String scheme, byte[] auth) {
 return ZooSession.getSession(keepers, timeout, scheme, auth);
}

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

protected ZooKeeper getSession(String keepers, int timeout, String scheme, byte[] auth) {
 return ZooSession.getSession(keepers, timeout, scheme, auth);
}