Jet 4.5 发布,分布式批处理和流处理引擎
Jet 是一个开源的、内存中的、分布式批处理和流处理引擎。你可以用它来处理大量的实时事件或大批量的静态数据集。为了给人一种规模感,Jet 的一个节点已经被证明可以每秒聚集1000万个事件,延迟低于10毫秒。 新功能: [sql] 动态 ClassDefinition 消除了在 IMap 中使用新的记录类型时重新启动集群的需要; 增强: [jdbc] 添加了一个选项,用于配置 JDBC Sink 的批处理大小; [sql] 优化了 SQL 聚合的内存占用; [sql] 现在你可以在 SQL 生成器函数中使用表达式了; [核心]从 IMap/ICache 中提取数据可能会由于同时创建过多的分区迭代器而导致 OOME; [核心] 删除了因工作被取消而发生的错误的误导性记录; [pipeline-api] 大大提高了滑动窗口中 pickAny 聚合操作的性能; 修复: [core]Jet 与 Java Logging Framework 的集成导致它无意中从关机 hook 中关闭了 System.out,这将破坏其他关机 hook; [core] 修复了 DAG.toDotString(),以...