连接器

更新时间: 2025-08-20 10:56:55

本文为您介绍实时计算Flink版支持的表类型的定义和连接器。

表类型的定义

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

  • 源表:是数据流的入口,用于从外部系统(如 Kafka、MySQL CDC)持续读取原始事件数据。

  • 维表:是用于补充信息的参考表,通常通过 JOIN 为流数据关联静态或低频更新的维度信息(如用户、商品信息)。

  • 结果表:是数据处理的出口,用于将计算后的结果(如聚合、关联后的数据)写入目标系统(如数仓、数据库、消息队列)。

支持的连接器

关系型数据库

NoSQL数据库

消息队列

数据仓库

数据湖

日志/对象存储服务

工具调试类

键值/时序数据库

通用类

连接器支持情况

连接器

支持类型

运行模式

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

上一篇: 开发参考 下一篇: 上下游组件扩缩容与增减分区对作业的影响及操作建议
阿里云首页 实时计算 Flink版 相关技术圈