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

Question

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

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

但这是错误的..。我知道当你调用这个实例时，就像是一个hazelcast的getDataStructure，jet它在hazelcast内部，我想我可以Jet.GetHazelcastInstance().GetDataStrcuture，因为我需要在一个新的集群中同步3个地图来进行复制…

这两个框架有什么不同？

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

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

有什么提示吗？

Answer 1

这两个框架有什么不同？

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

从5.0版开始，这两个产品被合并，当你使用Hazelcast时，你也可以通过getJet()获得喷气机引擎。

为什么我可以做hazelcast.GetDataStrcuture("wololo")；但是我不能做wololo

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

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

会给你同样的地图。

我不能完全理解3张地图的问题。是否要写入本地映射(或多个映射)，然后执行WAN复制？或者，您是否希望写入另一个集群中的映射(使用Sinks#remoteMap)？