在DataphinRealtime Compute引擎下,您可通過即時任務建立即時資料源對應的表類型。本文為您介紹Dataphin各Realtime Compute引擎支援的即時資料源及對應的讀寫支援。
Ververica Flink支援的即時資料源
|
儲存類型 |
資料來源類型 |
元表 |
讀 |
寫 |
維表讀 |
|
巨量資料儲存 |
MaxCompute |
支援 |
支援 |
支援 |
支援 |
|
Hologres |
支援 |
支援 |
支援 |
- |
|
|
Hudi |
支援 |
支援 |
支援 |
- |
|
|
StarRocks |
支援 |
支援 |
支援 |
- |
|
|
Lindorm(計算引擎) |
- |
- |
支援 |
支援 |
|
|
關係型資料庫 |
PolarDB |
- |
支援 |
支援 |
- |
|
PolarDB-X(原DRDS) |
支援 |
- |
支援 |
支援 |
|
|
MySQL |
支援 |
支援(CDC) |
支援 |
支援 |
|
|
PostgreSQL |
支援 |
支援 |
- |
- |
|
|
AnalyticDB for MySQL 3.0 |
支援 |
- |
支援 |
支援 |
|
|
AnalyticDB for PostgreSQL |
支援 |
- |
支援 |
支援 |
|
|
Oracle |
- |
- |
支援 |
- |
|
|
ClickHouse |
支援 |
- |
支援 |
- |
|
|
訊息佇列 |
Log Service |
支援 |
支援 |
支援 |
- |
|
Kafka |
支援 |
支援 |
支援 |
- |
|
|
RocketMQ |
支援 |
支援 |
支援 |
支援 |
|
|
NoSQL |
Elasticsearch |
支援 |
支援 |
支援 |
支援 |
|
Aliyun HBase |
支援 |
- |
支援 |
支援 |
|
|
Tablestore |
支援 |
- |
支援 |
支援 |
|
|
Redis |
支援 |
- |
支援 |
支援 |
|
|
Lindorm(寬表) |
支援 |
- |
支援 |
支援 |
Alibaba Blink支援的即時資料源
|
儲存類型 |
資料來源類型 |
讀 |
寫 |
維表讀 |
|
巨量資料儲存 |
MaxCompute |
支援 |
支援 |
支援 |
|
DataHub |
支援 |
支援 |
- |
|
|
Hologres |
支援 |
支援 |
支援 |
|
|
關係型資料庫 |
PolarDB-X(原DRDS,同RDS) |
- |
支援 |
支援 |
|
AnalyticDB for MySQL 2.0 |
- |
支援 |
- |
|
|
AnalyticDB for MySQL 3.0 |
- |
支援 |
支援 |
|
|
訊息佇列 |
Log Service(SLS/LOG_HUB) |
支援 |
支援 |
- |
|
Kafka |
支援 |
支援 |
- |
|
|
RocketMQ |
支援 |
支援 |
- |
|
|
NoSQL |
Elasticsearch |
支援 |
支援 |
不支援 |
|
Aliyun HBase |
- |
支援 |
支援 |
|
|
Tablestore |
- |
支援 |
支援 |
|
|
Redis |
- |
支援 |
支援 |
Apache Flink支援的即時資料源
|
儲存類型 |
資料來源類型 |
元表 |
讀 |
寫 |
維表讀 |
|
巨量資料儲存 |
Hive |
支援(僅CDH6.x Hive 2.1.1、CDP7.x Hive 3.1.3、亞信DP5.x Hive3.1.0版本支援) |
支援 |
支援 |
支援 |
|
Hive(hudi) |
支援 |
支援 |
支援 |
- |
|
|
Hive(Iceberg) |
- |
支援(僅支援原生DDL方式) |
支援(僅支援原生DDL方式) |
||
|
Hive(paimon) |
支援(僅Aliyun EMR5.x Hive3.1.x、CDH6.x Hive 2.1.1版本支援) |
支援(Aliyun EMR5.x Hive3.1.x,需flink1.20.1,支援Paimon1.0.1;CDH6.x Hive 2.1.1,需flink1.15.3,支援Paimon0.8.2) |
支援(Aliyun EMR5.x Hive3.1.x,需flink1.20.1,支援Paimon1.0.1;CDH6.x Hive 2.1.1,需flink1.15.3,支援Paimon0.8.2) |
支援(Aliyun EMR5.x Hive3.1.x,需flink1.20.1,支援Paimon1.0.1;CDH6.x Hive 2.1.1,需flink1.15.3,支援Paimon0.8.2) |
|
|
Hudi |
支援 |
支援 |
支援 |
- |
|
|
Doris |
支援 |
支援(flink1.14及flink1.15) |
支援(flink1.14及flink1.15) |
支援 |
|
|
SelectDB |
- |
- |
支援 |
- |
|
|
Paimon |
支援 |
支援(flink1.14及flink1.15) |
支援(flink1.14及flink1.15) |
- |
|
|
StarRocks |
支援 |
支援 |
支援 |
- |
|
|
TDH Inceptor(9.3.x) |
支援 |
- |
支援 |
支援 |
|
|
關係型資料來源 |
MySQL |
支援 |
支援(CDC) |
支援 |
支援 |
|
SAP HANA |
支援 |
支援 |
- |
- |
|
|
Microsoft SQL Server |
支援 |
支援(CDC) |
支援(僅flink 1.20.x) |
- |
|
|
PostgreSQL |
支援 |
支援 |
支援 |
支援 |
|
|
AnalyticDB for PostgreSQL |
支援 |
- |
支援 |
- |
|
|
OceanBase |
支援 |
支援(CDC) |
|||
|
Oracle |
支援 |
支援(CDC) |
支援 |
- |
|
|
ClickHouse |
支援 |
- |
支援(僅flink 1.15) |
- |
|
|
TiDB |
支援 |
支援(CDC) |
- |
- |
|
|
GaussDB(DWS) |
- |
- |
支援 |
支援 |
|
|
TDSQL for PostgreSQL |
支援(僅flink1.20) |
支援(CDC、僅flink1.20) |
支援(僅flink1.20) |
- |
|
|
訊息佇列 |
Log Service |
支援 |
支援(僅flink 1.15) |
支援(僅flink 1.15) |
- |
|
Kafka |
支援 |
支援 |
支援 |
- |
|
|
RabbitMQ |
支援 |
支援 |
支援 |
- |
|
|
RocketMQ |
支援 |
支援 |
支援 |
- |
|
|
NoSQL |
HBase 0.9.4 |
- |
- |
支援 |
支援 |
|
HBase 1.1.x |
支援 |
- |
支援 |
支援 |
|
|
HBase 2.x |
支援 |
- |
支援 |
支援 |
|
|
Elasticsearch |
支援 |
- |
支援 |
- |
|
|
Redis |
支援 |
- |
支援(僅Flink 1.15) |
支援(僅Flink 1.15) |
|
|
MongoDB |
支援 |
支援(CDC) |
- |
- |
|
|
半結構化儲存 |
SAP TABLE |
- |
支援 |
- |
- |
|
檔案 |
OSS |
支援 |
- |
支援 |
- |
FusionInsight Flink支援的即時資料源
|
儲存類型 |
資料來源類型 |
讀 |
寫 |
維表讀 |
|
關係型資料庫 |
MySQL |
支援(CDC) |
支援(JDBC) |
支援(JDBC) |
|
PostgreSQL |
- |
支援(JDBC) |
支援(JDBC) |
|
|
Oracle |
- |
支援(JDBC) |
支援(JDBC) |
|
|
訊息佇列 |
Kafka |
支援 |
支援 |
- |