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

ZooLock.getSessionId介绍

暂无

代码示例

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

public long getSessionId() throws KeeperException, InterruptedException {
 return getSessionId(getLockDataZooCache, path);
}

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

@Override
public boolean isLockHeld(String tserver, String session) {
 return ZooLock.getSessionId(zc, root + "/" + tserver) == Long.parseLong(session, 16);
}

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

/**
 * Look up the TabletServers in ZooKeeper and try to find a sessionID for this server reference
 *
 * @param hostAndPort
 *          The host and port for a TabletServer
 * @return The host and port with the session ID in square-brackets appended, or the original
 *         value.
 */
static String qualifyWithZooKeeperSessionId(String zTServerRoot, ZooCache zooCache,
  String hostAndPort) {
 long sessionId = ZooLock.getSessionId(zooCache, zTServerRoot + "/" + hostAndPort);
 if (sessionId == 0) {
  return hostAndPort;
 }
 return hostAndPort + "[" + Long.toHexString(sessionId) + "]";
}

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

private static TServerInstance getTServerInstance(String address, ZooLock zooLock) {
 while (true) {
  try {
   return new TServerInstance(address, zooLock.getSessionId());
  } catch (KeeperException | InterruptedException e) {
   log.error("{}", e.getMessage(), e);
  }
  sleepUninterruptibly(1, TimeUnit.SECONDS);
 }
}

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

public TServerInstance getTabletSession() {
 String address = getClientAddressString();
 if (address == null)
  return null;
 try {
  return new TServerInstance(address, tabletServerLock.getSessionId());
 } catch (Exception ex) {
  log.warn("Unable to read session from tablet server lock" + ex);
  return null;
 }
}

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

TServerInstance instance = new TServerInstance(clientAddress, getLock().getSessionId());
TabletLocationState tls = null;
try {

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

public long getSessionId() throws KeeperException, InterruptedException {
 return getSessionId(getLockDataZooCache, path);
}

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

@Override
public boolean isLockHeld(String tserver, String session) {
 try {
  return ZooLock.getSessionId(zc, root + "/" + tserver) == Long.parseLong(session, 16);
 } catch (KeeperException e) {
  throw new RuntimeException(e);
 } catch (InterruptedException e) {
  throw new RuntimeException(e);
 }
}

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

/**
 * Look up the TabletServers in ZooKeeper and try to find a sessionID for this server reference
 *
 * @param hostAndPort
 *          The host and port for a TabletServer
 * @return The host and port with the session ID in square-brackets appended, or the original
 *         value.
 */
static String qualifyWithZooKeeperSessionId(String zTServerRoot, ZooCache zooCache,
  String hostAndPort) {
 try {
  long sessionId = ZooLock.getSessionId(zooCache, zTServerRoot + "/" + hostAndPort);
  if (0 == sessionId) {
   return hostAndPort;
  }
  return hostAndPort + "[" + Long.toHexString(sessionId) + "]";
 } catch (InterruptedException | KeeperException e) {
  log.warn("Failed to communicate with ZooKeeper to find session ID for TabletServer.");
  return hostAndPort;
 }
}