修订记录

发布日期 修订记录
2026-06-30 第四次正式发布。
发布OmniStream 1.3.0:
在SQL场景中,支持WindowAgg、WindowJoin算子,Calc算子支持UDF函数注册,Calc算子支持JSON_VALUE、JSON_QUERY、COALESCE、PROCTIME_MATERIALIZE、CHAR_LENGTH、TO_TIMESTAMP_LTZ内置函数,Calc算子支持INTEGER、TIMESTAMP_WITH_LOCAL_TIMEZONE(3)数据类型。
2026-03-30 第三次正式发布。
发布OmniStream 1.2.0:
增加UDF翻译工具所使用依赖的头文件安装内容,在有状态场景下使能OmniStateStore加速特性。
2025-12-30 第二次正式发布。
发布OmniStream 1.1.0:
在SQL场景中,新增支持task级别算子回退机制;在DataStream场景中,KeyedCoProcess算子支持checkpoint、restore。
2025-06-30 第一次正式发布。
发布OmniStream 1.0.0:
  • SQL:实现了Calc、GroupAgg、Join、Deduplicate、Rank、Window、Kafka Source/Sink算子加速;实现了高效数据组织方式OmniVec;实现了对内存和RocksDB状态后端的支持。
  • DataStream:实现了Kafka Source、Kafka Sink、Map、FlatMap、Reduce、Filter算子加速;实现了UDF基础框架和UDF翻译基础库,支持UDF自动Native化框架成功运行DataStream Wordcount等有状态和无状态用例;实现了对内存状态后端的支持。