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

更新说明

鲲鹏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自动Native化框架,成功通过DataStream Wordcount等有状态和无状态用例。
  • 实现了对内存状态后端的支持。

修改特性

删除特性