使用 Hazelcast 和 Hazelcast Jet 的数据结构问题答案

【问题标题】：Problem with data structures using Hazelcast and Hazelcast Jet使用 Hazelcast 和 Hazelcast Jet 的数据结构问题
【发布时间】：2021-12-14 08:55:09
【问题描述】：

我在使用 jet 和 hazelcast 时遇到了一些问题，但我的问题是出于逻辑目的，我有一个类将带来所有数据，当我们启动客户端时，我们得到了一个队列和 2 张地图，但是尚未调用另一张地图，当我启动 hazelcast jet 实例并在使用 Sink 时处理所有数据时，我放了这个：

        rulesIntoTransaction.writeTo(Sinks.map(jet.getHazelcastInstance().getMap(RULESRESULT_MAP), Transaction::getTransactionId, Transaction::getRulesResult));

但这是错误的......要复制的新集群...

这两个框架有什么区别？

为什么我可以做 hazelcast.GetDataStrcuture("wololo");但我不能做 jet.getHazelcastInstance.getDataStructure("wololo");？

因为要被复制，我需要不同集群中的 3 张地图，但如果其中 2 张在 hazelcast 上而另一个在 hazelcast jet 上，我就无法做到

有什么提示吗？

【问题讨论】：

标签： hazelcast hazelcast-imap hazelcast-jet

【解决方案1】：

这两个框架有什么区别？

Hazelcast 是内存数据网格。 Hazelcast Jet 是一个流媒体引擎。 Hazelcast Jet 是建立在 Hazelcast 之上的，所以当你运行 Hazelcast Jet 时，你也运行 Hazelcast，没有它是不可能的。您可以在 JetInstance 上调用 getHazelcastInstance 以检索 Hazelcast 成员实例。

自 5.0 版以来，这两个产品被合并，当您使用 Hazelcast 时，您还可以通过 getJet() 获得 Jet 引擎。

为什么我可以做 hazelcast.GetDataStrcuture("wololo");但我不能做 jet.getHazelcastInstance.getDataStructure("wololo");？

你可以，这些是等价的，例如：

jet.getHazelcastInstance.getMap("wololo"):
jet.getMap("wololo");

会给你同样的地图。

我不完全理解 3 张地图的问题。您想写入本地地图（或地图）然后进行 WAN 复制吗？或者您想写入另一个集群中的地图（使用Sinks#remoteMap）？

【讨论】：