功能介绍
全托管Flink为您提供企业级服务
完全兼容生态
- 100%兼容开源 Flink 生态，迁移成本低 - 插件化企业级增强，性能优异
全托管一站式
- 全托管 Flink 服务，操作简单易用 - 开箱即用，免运维
Serverless 弹性
- 租户级端到端（计算、网络、存储）安全隔离 - 基于火山引擎 VKE/VCI 弹性扩展能力
私有化部署
- 支持私有化部署 - 云原生流批一体引擎
交互协同
- 交互式作业执行方式 - 分析结果可视化展示
企业级安全
- 基于火山引擎 IAM 及 OpenLDAP 用户及角色控制 - 基于 Ranger 的权限管理及审计
端到端流批一体
- 统一计算引擎（同时支持流式计算与批式计算） - 内置与 Kafka 及自研 MQ 连接器
功能介绍
全托管Flink为您提供企业级服务
完全兼容生态
- 100%兼容开源 Flink 生态，迁移成本低 - 插件化企业级增强，性能优异
全托管一站式
- 全托管 Flink 服务，操作简单易用 - 开箱即用，免运维
Serverless 弹性
- 租户级端到端（计算、网络、存储）安全隔离 - 基于火山引擎 VKE/VCI 弹性扩展能力
私有化部署
- 支持私有化部署 - 云原生流批一体引擎
交互协同
- 交互式作业执行方式 - 分析结果可视化展示
企业级安全
- 基于火山引擎 IAM 及 OpenLDAP 用户及角色控制 - 基于 Ranger 的权限管理及审计
端到端流批一体
- 统一计算引擎（同时支持流式计算与批式计算） - 内置与 Kafka 及自研 MQ 连接器
产品架构
企业级全托管流式计算引擎完整架构
点击查看完整架构
产品架构
企业级全托管流式计算引擎完整架构
产品优势
核心企业级增强能力
SQL 增强
支持 Window Mini-Batch，支持算子级别 Debug 输出，支持表达式复用，支持新增聚合指标可以从 Checkpoint 恢复，支持所有 Source、Sink 并行度设置，支持所有 Connector 限速等
State & Checkpoint 增强
支持Regional Checkpoint，支持HDFS小文件合并，支持Checkpoint 多策略触发，支持单点 Fast Checkpoint
CEP 增强
支持单流多规则及规则动态更新能力，支持 notFollowedBy 语义能力，支持 Key 级别 Watermark 能力
Runtime 增强
支持单点恢复，支持启动慢节点，支持推测执行，超大规模调度优化，调度均衡优化
SQL 增强
支持 Window Mini-Batch，支持算子级别 Debug 输出，支持表达式复用，支持新增聚合指标可以从 Checkpoint 恢复，支持所有 Source、Sink 并行度设置，支持所有 Connector 限速等
State & Checkpoint 增强
支持Regional Checkpoint，支持HDFS小文件合并，支持Checkpoint 多策略触发，支持单点 Fast Checkpoint
CEP 增强
支持单流多规则及规则动态更新能力，支持 notFollowedBy 语义能力，支持 Key 级别 Watermark 能力
Runtime 增强
支持单点恢复，支持启动慢节点，支持推测执行，超大规模调度优化，调度均衡优化
应用场景
实时监控、实时数仓等多维场景
实时 ETL
丰富的内置 Connector，全面支持各种数据源及存储，企业级 SQL 能力高效构建实时数据处理平台
实时监控
提供状态管理等支持，内置CEP复杂事件处理模块，协助企业简化规则告警配置、降低监测平台维护成本
实时数仓
海量数据实时处理及高并发实时入仓，协助企业建立数字化运营体系，为经营决策提供实时数据支持
实时推荐
实时样本拼接能力，通过实时模型训练，创建实时增量模型，为客户提供更加精准和实时的推荐能力
应用场景
实时监控、实时数仓等多维场景
实时 ETL
丰富的内置 Connector，全面支持各种数据源及存储，企业级 SQL 能力高效构建实时数据处理平台
实时监控
提供状态管理等支持，内置CEP复杂事件处理模块，协助企业简化规则告警配置、降低监测平台维护成本
实时数仓
海量数据实时处理及高并发实时入仓，协助企业建立数字化运营体系，为经营决策提供实时数据支持
实时推荐
实时样本拼接能力，通过实时模型训练，创建实时增量模型，为客户提供更加精准和实时的推荐能力
客户案例
实时数据处理及推荐首选合作伙伴
抖音短视频
穿山甲
使用指南
欢迎查看使用指南