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

应用场景

在应用特性前,请先了解OmniStream Flink Native化特性的应用场景。

Apache Flink是一个开源的实时流处理引擎,适用于实时数据处理。随着业务的快速发展和数据量的急剧增长在某些高负载场景下,Flink性能瓶颈逐渐显现,尤其是在互联网场景下,相对于友商存在一定的性能差距。OmniStream Flink Native化特性是一种采用Native Code(C/C++)实现Flink SQL算子来提高查询性能的特性,通过对Flink引擎进行Native化改造,以实现性能的显著提升。

当前OmniStream Flink Native化支持Flink 1.16.3引擎,用户输入SQL在引擎执行时会转为一系列的算子,OmniStream Flink Native化特性提供Native算子,使用Native算子来替换Flink开源软件对应算子,从而加速Flink引擎的执行,提升分析性能。