支持哪些连接器-实时计算 Flink版(Flink)-阿里云帮助中心

表类型的定义

阿里云实时计算Flink版通过Flink SQL定义表对上下游存储进行映射或者使用Datastream API进行连接来实现读写。支持以下几种Flink SQL表类型的定义：

源表：是数据流的入口，用于从外部系统（如 Kafka、MySQL CDC）持续读取原始事件数据。
维表：是用于补充信息的参考表，通常通过 JOIN 为流数据关联静态或低频更新的维度信息（如用户、商品信息）。
结果表：是数据处理的出口，用于将计算后的结果（如聚合、关联后的数据）写入目标系统（如数仓、数据库、消息队列）。

支持的连接器

关系型数据库

NoSQL数据库

消息队列

数据仓库

数据湖

日志/对象存储服务

工具调试类

键值/时序数据库

通用类

连接器支持情况

连接器	支持类型			运行模式	API类型	是否支持更新或删除结果表数据
连接器	源表	维表	结果表	运行模式	API类型	是否支持更新或删除结果表数据
MySQL 说明支持连接RDS MySQL版、PolarDB MySQL版及自建MySQL。	√	√	√	流模式	SQL、DataStream和数据摄入YAML	是
实时数仓Hologres	√	√	√	流模式和批模式	SQL、DataStream和数据摄入YAML	是
消息队列Kafka	√	×	√	流模式	SQL、DataStream和数据摄入YAML	不支持更新和删除结果表数据，只支持插入数据。
大数据计算服务MaxCompute	√	√	√	流模式和批模式	SQL和DataStream	不支持更新和删除结果表数据，只支持插入数据。
流式数据湖仓Paimon	√	√	√	流模式和批模式	SQL和数据摄入YAML	是
日志服务SLS	√	×	√	流模式	SQL和DataStream	不支持更新和删除结果表数据，只支持插入数据。
StarRocks	√	√	√	流模式和批模式	SQL、DataStream和数据摄入YAML	是
数据总线DataHub	√	×	√	流模式和批模式	SQL和DataStream	不支持更新和删除结果表数据，只支持插入数据。
MongoDB	√	√	√	流模式	SQL和DataStream	是
JDBC	√	√	√	流模式和批模式	SQL	是
对象存储OSS	√	×	√	流模式和批模式	SQL和DataStream	不支持更新和删除结果表数据，只支持插入数据。
云数据库RDS MySQL版说明后续将不再支持云数据库RDS MySQL版连接器，建议您直接使用MySQL连接器。	×	√	√	流模式和批模式	SQL	是
云消息队列 RocketMQ 版	√	×	√	流模式	SQL和DataStream	不支持更新和删除结果表数据，只支持插入数据。
云原生多模数据库Lindorm	×	√	√	流模式	SQL	是
云数据库Tair（Redis开源版）	×	√	√	流模式	SQL	是
云数据库Tair（Tair企业版）	×	×	√	流模式	SQL	是
云数据库HBase	×	√	√	流模式	SQL	是
云原生数据仓库 AnalyticDB MySQL版 3.0	√	√	√	流模式和批模式	SQL	是
云原生数据仓库AnalyticDB PostgreSQL版（ADB PG）	×	√	√	流模式和批模式	SQL	是
PolarDB PostgreSQL版（Oracle语法兼容1.0）	×	×	√	流模式和批模式	SQL	是
Upsert Kafka	√	×	√	流模式	SQL和数据摄入YAML	是
Elasticsearch	√	√	√	流模式和批模式	SQL和DataStream	是
ClickHouse	×	×	√	流模式和批模式	SQL	是
表格存储Tablestore（OTS）	√	√	√	流模式	SQL	是
SelectDB	×	×	√	流模式和批模式	DataStream和SQL	是
时序数据库InfluxDB	×	×	√	流模式	SQL	否
Postgres CDC（公测中）	√	×	×	流模式	SQL	不涉及
OceanBase（公测中）	√	√	√	流模式和批模式	SQL	是
Milvus（公测中）	×	×	√	流模式	SQL	是
Iceberg	√	×	√	流模式和批模式	SQL	是
模拟数据生成Faker	√	√	×	流模式和批模式	SQL	不涉及
Blackhole	×	×	√	流模式和批模式	SQL	是
Datagen	√	×	×	流模式和批模式	SQL	不涉及
Print	×	×	√	流模式和批模式	SQL和数据摄入YAML	是
Hudi（退役中）	√	×	√	流模式和批模式	SQL和DataStream	是