鲲鹏社区首页
中文
注册
我要评分
文档获取效率
文档正确性
内容完整性
文档易理解
在线提单
论坛求助

更新说明

鲲鹏BoostKit大数据OmniStream Flink Native化特性使用Native Code(C/C++)实现开源软件对应算子,从而加速Flink引擎的执行,提升查询性能。

新增特性

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化框架跑通京东wordcount用例和美团无状态用例。
  • 实现了对内存状态后端的支持。

修改特性

删除特性