org.apache.accumulo.fate.zookeeper.ZooSession.sessionKey()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 10:12:24 26 4

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;
}

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;
}

26 4 0

• sqoop - 警告 :/usr/lib/sqoop/. ./accumulo 不存在! Accumulo 导入将失败。请将 $ACCUMULO_HOME 设置为 Accumulo 安装的根目录

  我的虚拟机详细信息: Cloudera 快速入门 VM 5.5.0 VM = VM 工作站 12 播放器 Windows = Windows 10/64 位 Java = Java 1.8 当我运行“

• hadoop - 如何删除所有 accumulo 表或为 accumulo 格式化 hadoop 文件

  我想为我的本地机器清除 accumulo 中的所有记录，并想删除在测试时创建的未使用的表。我发现可以从 accumulo shell 使用 delete table 命令，但是这将需要大量手动工作来删

• node.js - 如何通过 Accumulo 代理客户端基于 rowkey 删除 Accumulo 中的记录

  我正在使用 Accumulo 1.6，并且希望通过 Nodejs 中的 Accumulo 代理客户端给定的 rowkey 来删除一些记录。 但是当我尝试将相同的行键放入deleteRows API 时

• accumulo - 如何删除累积的实例？

  我在初始化 accumulo 时创建了一个实例，方法是调用 累积初始化 但现在我想删除该实例，并且我想创建一个新实例。 任何人都可以帮助做到这一点吗？ 最佳答案 从 HDFS 中删除 $ACCUMUL

• accumulo - 配置累加器时出现问题

  在我的系统中，Hadoop和Zookeeper正常工作。现在我刚刚配置了Accumulo。但是当我要通过以下方式初始化Accumulo时 累积初始 它显示以下错误。 [root@hydDev32 bi

• installation - Accumulo 卡住无法启动

  我一直在尝试安装 Accumulo 并试用了几天，但它甚至在开始之前就已经备货了。我最终使用了安装了 Hadoop 和 Zookeeper 的 HortonWorks Sandbox。我按照 Accm

• apache - 将数据写入Apache Accumulo

  我想将流数据写入accumulo!。有任何用于累积写入数据的API。可以用python代替java吗？ 最佳答案 通过BatchWriter实例化查看Connector。 Accumulo Thrif

• java - Accumulo - 获取正确排序的扫描仪结果

  有没有办法对扫描仪获得的条目进行排序？我遇到的问题是，我有后缀索引来减少重复的行 ID，并且当我扫描时，我没有得到完美的升序有序列表。例如，我得到如下所示的内容: RowId: 2013-08-05

• java - accumulo 中插入表的行数

  我已将一些行插入到 Accumulo 的表格中。有些行是新创建的，有些行是更新的。 如何找到插入或更新到Java 中的累加表？ def obj= jsonObject["obj"] for(entry

• apache - Accumulo -- 添加一个新节点

  我正在努力学习 Accumulo。但我有几个问题无法直接找到: 首先，我们能否在不停机的情况下向现有的 Accumulo 系统添加新服务器？如果是，则新节点将由 master 安排其共享(DB 数据)

• hadoop - accumulo 无法加载平板电脑

  Accumulo 无法加载、删除或创建新表。我的默认用户是 root。 Master 和 tablet server 和 zookeeper 还活着。 早些时候我试图通过使用 accululo ini

• hadoop - Accumulo 表名称映射问题

  我的 Accumulo 实例已损坏。当我启动我的实例时，它抛出了一个错误，指出我的元数据表已损坏。然后我从 hdfs 的 Accumulo 目录备份了我的数据，并在我的实例上做了一个初始化。我没有意识

• hadoop - Accumulo:没有平板电脑服务器

  ./bin/accumulo shell -u root Password: ****** 2015-02-14 15:18:28,503 [impl.ServerClient] WARN : The

• performance - Accumulo 高速摄取选项

  简而言之，我有一个客户想要将一堆 ASCII 文本文件(又名“输入文件”)中包含的数据摄取到 Accumulo 中。 这些文件是从不同的数据馈送设备输出的，并将在非 Hadoop/非 Accumulo

• hadoop - 如何更改 Accumulo 平板电脑服务器名称以从远程客户端访问？

  我一直在运行一个单节点 Accumulo 应用程序，只要客户端应用程序在同一台机器上运行，它就一直运行良好。现在我需要将客户端迁移到另一台机器，但运行应用程序会给出以下警告，不允许程序继续: WARN

• java - Accumulo 范围 - 不包含结束键

  我正在学习 Accumulo，似乎无法让 Range 中指定的结束键包含在内。我的代码如下。我尝试在 Range 中将 endKeyInclusive 显式设置为 true，但这没有帮助。 Batch

• java - 限制 Accumulo 中的查询量

  请问有没有办法让accumlo限制用户的扫描量？例如，每天只允许其他用户进行 10 次扫描。 最佳答案 Accumulo 有一个可插拔接口(interface) authentication和 tab

• java - 获取 Accumulo 实例名称

  我想使用 GeoMesa(Accumulo 的 GIS 扩展)并使用 Docker 对其进行虚拟化，就像 this repo 一样。现在我想使用 Java 连接到 Accumulo 实例: Inst

• c# - Accumulo createBatchScanner 范围未按预期工作

  我无法让批处理扫描仪只扫描特定行，当设置启动和停止键到相同的东西时我没有返回任何条目，当使用扫描仪时我得到这个异常: "java.lang.IllegalArgumentException: Star

• java - Accumulo - 将突​​变集合添加到超过缓冲区限制的 batchwriter

  当您向总大小超过设置缓冲区的 BatchWriter 添加 Mutations 集合时会发生什么？ BatchWriter 是否只是说好的，我将处理我设置的内容，然后再处理其余的？ 最佳答案 Accu