火山引擎流式计算 Flink 版 100% 兼容开源 Apache Flink，但同时包含插件化的企业增强和集团最佳实践。本文介绍流式计算 Flink 版的核心功能优势。
核心优势 | 核心优势描述 |
|---|
SQL 增强 | - Window Mini-Batch
- 支持 Window Offset
- 维表延迟 Join
- 支持维表 Keyby
- 支持 Temporal Table Function DDL & Left Outer Join
- 支持 pb format
- 支持算子级别Debug输出
- 支持表达式复用
- 支持新增聚合指标可以从 Checkpoint 恢复
- 支持所有 Source、Sink 并行度设置；支持所有 Connector 限速
|
State & Checkpoint增强 | - Regional Checkpoint
- HDFS小文件合并
- Checkpoint 多策略触发
- 单点 Fast Checkpoint
|
CEP 增强 | - 单流多规则能力
- 规则动态更新能力
- notFollowedBy 语义能力
- Key 级别 Watermark 能力
|
Runtime 增强 | |