org.apache.ignite.spi.discovery.zk.internal.ZookeeperClient.zk()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 09:51:44 28 4

/** */
  public String getZkSessionId() {
    if (rtState.zkClient != null && rtState.zkClient.zk() != null)
      return Long.toHexString(rtState.zkClient.zk().getSessionId());
    else
      return null;
  }
}

/**
 * @throws Exception If failed.
 */
@Test
public void testClose() throws Exception {
  startZK(1);
  final ZookeeperClient client = createClient(SES_TIMEOUT);
  client.createIfNeeded("/apacheIgnite1", null, CreateMode.PERSISTENT);
  client.zk().close();
  GridTestUtils.assertThrows(log, new Callable<Void>() {
    @Override public Void call() throws Exception {
      client.createIfNeeded("/apacheIgnite2", null, CreateMode.PERSISTENT);
      return null;
    }
  }, ZookeeperClientFailedException.class, null);
}

/**
 * @throws Exception If failed.
 */
@Test
public void testSaveLargeValue() throws Exception {
  startZK(1);
  final ZookeeperClient client = createClient(SES_TIMEOUT);
  byte[] data = new byte[1024 * 1024];
  String basePath = "/ignite";
  assertTrue(client.needSplitNodeData(basePath, data, 2));
  List<byte[]> parts = client.splitNodeData(basePath, data, 2);
  assertTrue(parts.size() > 1);
  ZooKeeper zk = client.zk();
  for (int i = 0; i < parts.size(); i++) {
    byte[] part = parts.get(i);
    assertTrue(part.length > 0);
    String path0 = basePath + ":" + i;
    zk.create(path0, part, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
  }
}

log.info("Node started join [nodeId=" + locNode.id() +
  ", instanceName=" + locNode.attribute(ATTR_IGNITE_INSTANCE_NAME) +
  ", zkSessionId=0x" + Long.toHexString(rtState.zkClient.zk().getSessionId()) +
  ", joinDataSize=" + joinDataBytes.length +
  (rtState.joinDataPartCnt > 1 ? (", joinDataPartCnt=" + rtState.joinDataPartCnt) : "") +

ZkPinger pinger = new ZkPinger(log, rtState.zkClient.zk(), zkPaths);

28 4 0

• ignite - 使用 Ignite 对象时来自 GridUnsafe 的 Apache Ignite IllegalAccessException

  这就是我的代码中的全部内容。这只是使用 Ignite 的典型方式: Ignite ignite = Ignition.ignite(); 我看到的错误信息是: WARNING: An illegal

• ignite - Apache Ignite 节点分段

  有时我会不断地对节点进行分段。它发生在一个大约有 40 个节点的集群中——它一次只发生在一个节点上。有几次它发生在正在进行一些繁重的 GC 工作时。另一方面，我看到类似的繁重的 GC 工作正在进行并且

• ignite - 如何在拓扑无效时禁用对 ignite 缓存的所有操作

  我有 2 个服务器节点和一个客户端节点。我正在使用 TopologyValidator 来验证拓扑。 如果任何服务器节点离开集群，我想禁用所有操作。 TopologyValidator 仅禁用更新操作

• ignite - Apache Ignite 的多个持久性存储

  我有一个用例，我必须为我的 ignite 集群支持多个持久性存储，例如缓存 A1 应该从数据库 db1 启动，缓存 B1 应该从数据库 db2 启动。这可以完成吗？。在 ignite 配置 XML 中

• ignite - Apache Ignite 容错

  我对分区模式下的 Ignite Cache 有几个问题 1)当Ignite集群中的节点发生故障时，如果故障节点是某个 key 的主节点，那么该节点的备份是否会成为新的主节点？ 2) 故障节点中的备份副

• ignite - Apache Ignite 定义可插入哈希算法

  在页面 https://ignite.apache.org/features/datagrid.html我找到了以下信息: “与其他键值存储不同，Ignite 使用可插入哈希算法确定数据局部性。每个客

• ignite - 基于apache ignite SQL查询中的列表字段的排序记录

  可以说我下面有一个对象Employee，它存储在ignite缓存中。 Employee{ int id; String name; List marksInorder;/

• ignite - Apache Ignite - 执行器中的池大小

  我正在尝试使用基于集群的执行器服务。 //获取启用集群的执行器服务。ExecutorService exec = ignite.executorService(); 是否有办法设置执行程序服务池中的线

• ignite - Apache Ignite.NET : some Ignite nodes fail to start up after update to v2. 9 - 检测到堆栈粉碎

  我在 Linux 节点上的 Kubernetes 集群中运行 Apache Ignite .Net。 最近我将我的 ignite 2.8.1 集群更新到了 v2.9。更新后，作为集群一部分的某些服务无

• ignite - 如何清理 Apache Ignite 缓存并重新开始？

  我有一个 3 节点的 ignite 集群和 1 个创建缓存的客户端。在开发和测试过程中，我不得不多次停止集群或中断缓存构建，现在整个系统都崩溃了。只有一个节点启动，其他节点崩溃。客户端被阻止，它什么也

• ignite - 在 apache Ignite 中触发

  任何人都可以告诉我 Apache Ignite 中是否有可用的基于时间的触发策略？ 我有一个对象在那个日期(时间戳)过期时有过期日期我想更新这个值并在缓存中覆盖它是否可以在 Apache Ignite

• ignite - 如何最好地在 Apache ignite 缓存上推送持续更新的有序数据

  用例 这是我们正在研究的拓扑 Server - 1 --> marketData缓存，保存不同的股价信息 客户端 - 1 --> 将数据推送到缓存 Client - 2 --> 持续查询，监听市场上的

• ignite - Apache Ignite 与 GridGain？

  我无法理解 Apache Ignite 和 GridGain 平台之间的区别。他们是平等的？或者 GridGain 是 Apache Ignite 实现的标准？ 最佳答案 来自 the website

• ignite - 了解 Apache Ignite 的分布式连接

  我们正在探索在我们的项目中使用 Apache Ignite。基本上，我们有几十个 oracle 表。我们想将每个表加载到 Ignite Cache 中，然后在这些缓存之间进行连接。我们的表之间有很多连

• ignite - 如何在 Quarkus 中使用 Apache Ignite？

  我无法在 Quarkus 中找到 Apache Ignite 依赖项，也无法在任何有人将 Apache Ignite 与 Quarkus 结合使用的示例中找到它。如果 Quarkus 当前不支持 Ap

• ignite - 使用 IgniteSet 作为 Ignite 连续查询的动态远程过滤器的一部分

  有没有人试过使用 IgniteSet 或类似的数据结构在连续查询上设置远程过滤器？没有太多关于 IgniteSet 如何工作的文档，因此这个问题。基本上我的用例如下: 我有一个使用 Ignite 实现

• ignite - Apache Ignite - 通过 sql 驱动程序查询缓存

  我在 Ignite 中创建了一个缓存，现在我正尝试通过 ignite 包中提供的 sqlline 查询它。在文档中，它只讨论创建表、索引、查询这些表等。但没有讨论以这种方式通过 ignite.getO

• ignite - Apache Ignite 在分布式缓存中存储 JSON Map

  我编写了下面的代码来从 JSON 文件中读取数据并将其推送到 Ignite 分布式缓存中，这段代码工作正常，但是，创建“ContainerAgg”类的要求对我来说是个问题。我们的数据结构不是预定义的，

• java - 将实体从一个 Ignite 缓存复制到另一个 Ignite 缓存的最快方法是什么？

  我正在寻找一种方法将具有给定键的所有实体从一个 Ignite 缓存复制到另一个。虽然不断获取新数据，但每 x 秒所有数据都必须复制到缓存 2。我尝试使用 EntryProcessor，因为我只需要就地

• ignite - Apache Ignite - 选择查询返回 0 条记录，但数据存在于缓存中

  我们使用的是 Apache Ignite 2.9.0。它是一个带有 Zookeeper 发现的 5 节点集群。 我们通过从 Intellij 执行 DDL 语句在 Ignite 中创建表。然后我们可以