Hazelcast Jet - 用例

标签 hazelcast hazelcast-jet

Hazelcast Jet 有哪些用例?有人开始用了吗?
我们的项目使用 Hazelcast 进行分布式映射保存键值对,并在这些键上进行分布式计算,以在保存键的节点上运行任务。我们也使用 NearCache 解决方案。

我很想知道 Hazelcast Jet 有何不同以及它解决了哪些问题?

最佳答案

从当前版本 (0.3) 开始,与仅向每个分区提交 Runnable 相比,Jet 的优势在于能够通过 Hazelcast 映射中使用的键以外的键执行分组。为了在分布式环境中工作,您必须将每个项目发送到负责其分组键的处理单元,这很容易从 Jet 获得。

此外,您可以构建一个多级级联的 groupBy 操作,您可以在数据流中使用 fork 以多种方式重用相同的中间结果,您可以构建一个管道,其中I/O 任务将其读取的数据的处理分配到所有 CPU 内核等...简而言之,就是成熟的 DAG 计算引擎提供的所有优势。

到 1.0 时,Jet 还将支持容错无限流处理、基于事件时间的窗口等。

关于Hazelcast Jet - 用例,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42372106/

相关文章:

wildfly - Hazelcast 需要作为现有集群中的客户端而不是成员连接

java - 分配处理时通常有多少开销?

java - 创建新的 Jet 自定义分区器

java - 如何在没有网络的情况下创建嵌入进程内/内存中的 Hazelcast 实例?

java - Hazelcast MapStrore#store()

java - 使用 hazelcast 时 map 未准备好

java - Spring session 惰性反序列化

hazelcast-jet - Hazelcast Jet Kafka 具有不可序列化的事件处理程序

java - 使用流 API 时使用 AddJar() 添加代码?

java - 在 Hazelcast Jet 中执行左、右和内连接