hazelcast-jet如何实现与hazelcast EntryProcessors不同的功能

Question

hazelcast-jet如何实现与早期通过在IMap中提交密钥上的EntryProcessors有很大不同的结果？

好奇地想知道。

Answer 1

引用Jet上的InfoQ article：

向分区发送runnable类似于单个DAG顶点的工作。Jet的优势来自于让顶点转换它读取的数据的能力，产生不再属于同一分区的项目，然后在将它们发送到下游顶点的同时重新洗牌，以便再次正确地划分它们。这对于任何类型的map-reduce操作都是必不可少的，在这种操作中，缩减单元必须观察具有相同密钥的所有数据项。为了最大限度地减少网络流量，Jet可以首先减少在本地成员上生成的数据片，然后将每个键只发送一个项目给远程成员，该项目组合了部分结果。

请注意，在条目处理器目前涵盖的相同或类似用例的上下文中，这只是一个优势。Jet可以从任何来源获取数据，并利用整个集群的计算资源来处理这些数据。