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