最新动态

1

更新OmniOperator特性。

发布OmniOperator 2.1.0：

• 新增InsertIntoHadoopFsRelationCommand支持插入HDFS、WriteFile支持ORC写入、Window支持Array数据分段、FileSourceScanExec支持Array数据读取、LocalLimitExec支持Array数据截取。
• 新增支持datediff、pmod、charTypeWriteSideCheck、least、concat_ws、get_json_object表达式。

鲲鹏BoostKit OmniRuntime大数据套件 OmniOperator算子加速 文档

2

更新OmniStream特性。

发布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)数据类型。

鲲鹏BoostKit OmniRuntime大数据套件 OmniStream Flink Native化 文档

3

更新OmniStateStore特性。

发布OmniStateStore 1.3.0。

通过调整RocksDB不同SST层级的压缩格式，结合软算压缩算法优化，降低状态Compaction过程中的压缩/解压缩开销，提升应用端到端吞吐。

鲲鹏BoostKit OmniRuntime大数据套件 OmniStateStore状态优化 文档

1

更新OmniRuntime特性。

• 发布OmniOperator 2.1.0：新增InsertIntoHadoopFsRelationCommand支持插入HDFS、WriteFile支持ORC写入、Window支持Array数据分段、FileSourceScanExec支持Array数据读取、LocalLimitExec支持Array数据截取；新增支持datediff、pmod、charTypeWriteSideCheck、least、concat_ws、get_json_object表达式。
• 发布OmniStream 1.2.0：增加UDF翻译工具所使用依赖的头文件安装内容，在有状态场景下使能OmniStateStore加速特性。
• 发布OmniStateStore 1.2.0：基于对接Flink和RocksDB的插件完成Flink有状态用例性能加速。对Flink进行轻量级修改，基于状态缓存和状态过滤技术，降低Flink对RocksDB的访问频次，提升有状态用例的IO性能。1.2.0版本进行了架构调整，与1.1.0以及1.0.0相互独立。

鲲鹏BoostKit OmniRuntime大数据套件 OmniOperator算子加速 文档

鲲鹏BoostKit OmniRuntime大数据套件 OmniStream Flink Native化 文档

鲲鹏BoostKit OmniRuntime大数据套件 OmniStateStore状态优化 文档