连接器
本文为您介绍实时计算Flink版支持的表类型的定义和连接器。
表类型的定义
阿里云实时计算Flink版通过Flink SQL定义表对上下游存储进行映射或者使用Datastream API进行连接来实现读写。支持以下几种Flink SQL表类型的定义:
源表:是数据流的入口,用于从外部系统(如 Kafka、MySQL CDC)持续读取原始事件数据。
维表:是用于补充信息的参考表,通常通过 JOIN 为流数据关联静态或低频更新的维度信息(如用户、商品信息)。
结果表:是数据处理的出口,用于将计算后的结果(如聚合、关联后的数据)写入目标系统(如数仓、数据库、消息队列)。
支持的连接器
关系型数据库 | NoSQL数据库 | 消息队列 |
数据仓库 | 数据湖 | 日志/对象存储服务 |
工具调试类 | 键值/时序数据库 | 通用类 |
连接器支持情况
连接器 | 支持类型 | 运行模式 | API类型 | 是否支持更新或删除结果表数据 | ||
源表 | 维表 | 结果表 | ||||
说明 支持连接RDS MySQL版、PolarDB MySQL版及自建MySQL。 | √ | √ | √ | 流模式 | SQL、DataStream和数据摄入YAML | 是 |
√ | √ | √ | 流模式和批模式 | SQL、DataStream和数据摄入YAML | 是 | |
√ | × | √ | 流模式 | SQL、DataStream和数据摄入YAML | 不支持更新和删除结果表数据,只支持插入数据。 | |
√ | √ | √ | 流模式和批模式 | SQL和DataStream | 不支持更新和删除结果表数据,只支持插入数据。 | |
√ | √ | √ | 流模式和批模式 | SQL和数据摄入YAML | 是 | |
√ | × | √ | 流模式 | SQL和DataStream | 不支持更新和删除结果表数据,只支持插入数据。 | |
√ | √ | √ | 流模式和批模式 | SQL、DataStream和数据摄入YAML | 是 | |
√ | × | √ | 流模式和批模式 | SQL和DataStream | 不支持更新和删除结果表数据,只支持插入数据。 | |
√ | √ | √ | 流模式 | SQL和DataStream | 是 | |
√ | √ | √ | 流模式和批模式 | SQL | 是 | |
√ | × | √ | 流模式和批模式 | SQL和DataStream | 不支持更新和删除结果表数据,只支持插入数据。 | |
说明 后续将不再支持云数据库RDS MySQL版连接器,建议您直接使用MySQL连接器。 | × | √ | √ | 流模式和批模式 | SQL | 是 |
√ | × | √ | 流模式 | SQL和DataStream | 不支持更新和删除结果表数据,只支持插入数据。 | |
× | √ | √ | 流模式 | SQL | 是 | |
× | √ | √ | 流模式 | SQL | 是 | |
× | × | √ | 流模式 | SQL | 是 | |
× | √ | √ | 流模式 | SQL | 是 | |
√ | √ | √ | 流模式和批模式 | SQL | 是 | |
× | √ | √ | 流模式和批模式 | SQL | 是 | |
× | × | √ | 流模式和批模式 | SQL | 是 | |
√ | × | √ | 流模式 | SQL和数据摄入YAML | 是 | |
√ | √ | √ | 流模式和批模式 | SQL和DataStream | 是 | |
× | × | √ | 流模式和批模式 | SQL | 是 | |
√ | √ | √ | 流模式 | SQL | 是 | |
× | × | √ | 流模式和批模式 | DataStream和SQL | 是 | |
× | × | √ | 流模式 | SQL | 否 | |
√ | × | × | 流模式 | SQL | 不涉及 | |
√ | √ | √ | 流模式和批模式 | SQL | 是 | |
× | × | √ | 流模式 | SQL | 是 | |
√ | × | √ | 流模式和批模式 | SQL | 是 | |
√ | √ | × | 流模式和批模式 | SQL | 不涉及 | |
× | × | √ | 流模式和批模式 | SQL | 是 | |
√ | × | × | 流模式和批模式 | SQL | 不涉及 | |
× | × | √ | 流模式和批模式 | SQL和数据摄入YAML | 是 | |
√ | × | √ | 流模式和批模式 | SQL和DataStream | 是 |