Jet 是一个开源的、内存中的、分布式批处理和流处理引擎。你可以用它来处理大量的实时事件或大批量的静态数据集。为了给人一种规模感,Jet 的一个节点已经被证明可以每秒聚集1000万个事件,延迟低于10毫秒。
ClassDefinition
pickAny
System.out
DAG.toDotString()
CREATE MAPPING
OR REPLACE
IF NOT EXISTS
DAG.toDotString(int defaultParallelism)
DAG.toDotString(int defaultLocalParallelism, int defaultQueueSize)
更多详情可查看:https://github.com/hazelcast/hazelcast-jet/releases/tag/v4.5
评论删除后,数据将无法恢复
Jet 4.5 发布,分布式批处理和流处理引擎
Jet 是一个开源的、内存中的、分布式批处理和流处理引擎。你可以用它来处理大量的实时事件或大批量的静态数据集。为了给人一种规模感,Jet 的一个节点已经被证明可以每秒聚集1000万个事件,延迟低于10毫秒。
新功能:
ClassDefinition消除了在 IMap 中使用新的记录类型时重新启动集群的需要;增强:
pickAny聚合操作的性能;修复:
System.out,这将破坏其他关机 hook;DAG.toDotString(),以显示正确的队列大小;CREATE MAPPING语法有一个漏洞,你可以在同一语句中同时使用OR REPLACE和IF NOT EXISTS;重大变化:
DAG.toDotString(int defaultParallelism)方法签名现在为DAG.toDotString(int defaultLocalParallelism, int defaultQueueSize)。调用者现在必须提供队列大小,如果不在边缘上重写,则将被显示。更多详情可查看:https://github.com/hazelcast/hazelcast-jet/releases/tag/v4.5