数据源(Source)指输入流计算系统的数据来源。在当前 SQL 模式作业中,数据源可以是消息队列 Kafka、数据库 MySQL 等。

数据目的(Sink)指流计算系统输出处理结果的目的地。在当前的 SQL 模式作业中,数据目的可以是消息队列 Kafka、数据库 MySQL、数据分析引擎 Elasticsearch Service 等。

您也可以上传自定义的 Connector 程序包,以支持更多的数据源和数据目的。

数据源名称 作为流数据源 作为批数据源 作为维表 作为 Append 数据目的 作为 Upsert 数据目的

消息队列 Kafka

支持

-

-

支持

-

消息队列 Upsert Kafka

支持

-

-

-

支持

数据库 MySQL

-

支持

支持

支持

支持

数据库 MySQL CDC

支持

-

-

-

-

数据库 PostgreSQL

-

支持

支持

支持

支持

数据库 PostgreSQL CDC

支持

-

-

-

-

列存储数据库 HBase

-

支持

支持

支持

支持

数据仓库 ClickHouse

-

-

-

支持

支持

数据分析引擎 Elasticsearch

-

-

-

支持

支持

分布式文件存储 HDFS

-

-

-

支持

-

数据生成器 DataGen

支持

支持

-

-

-

数据生成器 Faker

支持

-

-

-

-

标准输出 Print

-

-

-

支持

-