gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-14 05:21:31 26 4
gpt4 key购买 nike

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

ZooLock.getSessionId介绍

暂无

代码示例

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

private static TServerInstance getTServerInstance(String address, ZooLock zooLock) {
 while (true) {
  try {
   return new TServerInstance(address, zooLock.getSessionId());
  } catch (KeeperException e) {
   log.error(e, e);
  } catch (InterruptedException e) {
   log.error(e, e);
  }
  UtilWaitThread.sleep(1000);
 }
}

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

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: org.apache.accumulo/accumulo-tserver

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: org.apache.accumulo/accumulo-server-base

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

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

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

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

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

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

@Override
public Set<TServerInstance> onlineTabletServers() {
 HashSet<TServerInstance> tservers = new HashSet<>();
 for (String tserver : getConnector().instanceOperations().getTabletServers()) {
  try {
   String zPath = ZooUtil.getRoot(getConnector().getInstance()) + Constants.ZTSERVERS + "/"
     + tserver;
   long sessionId = ZooLock.getSessionId(new ZooCache(getCluster().getZooKeepers(),
     getConnector().getInstance().getZooKeepersSessionTimeOut()), zPath);
   tservers.add(new TServerInstance(tserver, sessionId));
  } catch (Exception e) {
   throw new RuntimeException(e);
  }
 }
 return tservers;
}

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

TServerInstance instance = new TServerInstance(location, zl.getSessionId());
Writer writer = MetadataTableUtil.getMetadataTable(context);
Assignment assignment = new Assignment(high, instance);

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com