应用场景

OmniStream Flink Native化特性协助用户在保持原有开发习惯和架构兼容性的基础上，有效提升Flink引擎的处理性能，特别是在大规模数据实时分析场景中，展现出更强的处理能力与更高的执行效率。

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算子将替代原有Flink开源算子，直接执行，从而实现性能的大幅提升。