使用Hazelcast和Hazelcast Jet的数据结构存在问题

Question

我对jet和hazelcast有一些问题，但出于逻辑目的，我的问题是，我有一个类，它将带来所有数据，当我们启动客户端时，我们得到一个队列和两个映射，但另一个映射尚未调用，当我启动hazelcast jet实例并在使用接收器时处理所有数据时，我放了以下内容：

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

但这是错误的。。。。我知道当你调用这个实例时，它就像hazelcast的getDataStructure，喷射它的内部hazelcast，我以为我可以喷射。GetHazelcastInstance（）。GetDataStrcuture，因为我需要在一个新集群中同步3个映射以进行wan复制。。。

这两个框架之间有什么区别？

为什么我可以做hazelcast。GetDataStrcuture（“wololo”）；但我不会做喷气式飞机。getHazelcastInstance。getDataStructure（“wololo”）；？

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

有什么提示吗？

Answer 1

这两个框架之间有什么区别？

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

从5.0版开始，这两个产品被合并了，当您使用Hazelcast时，您还可以通过getJet（）获得Jet引擎。

为什么我能做hazelcast。GetDataStrcuture（“wololo”）；但我做不到。getHazelcastInstance。getDataStructure（“wololo”）；？

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

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

我会给你同样的地图。

我不完全理解3张地图的问题。是否要写入本地映射，然后执行WAN复制？或者您想写入另一个集群中的映射（使用接收器#remoteMap）？