更新说明
鲲鹏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等有状态和无状态用例。
- 实现了对内存状态后端的支持。
修改特性
无
删除特性
无
父主题: V1.0.0