在DataphinRealtime Compute引擎下,您可通過即時任務建立即時資料源對應的表類型。本文為您介紹Dataphin各Realtime Compute引擎支援的即時資料源及對應的讀寫支援。
Ververica Flink支援的即時資料源
儲存類型 | 資料來源類型 | 讀 | 寫 | 維表讀 |
巨量資料儲存 | MaxCompute | 支援 | 支援 | 支援 |
DataHub | 支援 | 支援 | - | |
Hologres | 支援 | 支援 | 支援 | |
資料湖 | Hudi | 支援 | 支援 | - |
Iceberg | 支援(僅支援原生DDL方式) | 支援(僅支援原生DDL方式) | - | |
關係型資料庫 | PolarDB | 支援 | 支援 | - |
PolarDB-X(原DRDS,同RDS) | - | 支援 | 支援 | |
AnalyticDB for MySQL 3.0 | - | 支援 | 支援 | |
AnalyticDB for PostgreSQL 6.0+ | - | 支援 | 支援 | |
Postgres | 支援(支援postgres-cdc) | - | - | |
MySQL | 支援(支援mysql-cdc) | 支援 | 支援 | |
Oracle | - | 支援 | - | |
RDS for MySQL(原DRDS) | - | 支援 | 支援 | |
訊息佇列 | Log Service(SLS/LOG_HUB) | 支援 | 支援 | - |
Kafka | 支援 | 支援 | - | |
RocketMQ | 支援 | 支援 | 支援 | |
NoSQL | Elasticsearch | 支援 | 支援 | 支援 |
Aliyun HBase | - | 支援 | 支援 | |
Tablestore | - | 支援 | 支援 | |
Redis | - | 支援 | 支援 | |
Lindorm(寬表) | - | 支援 | 支援 | |
StarRocks | 支援 | 支援 | - |
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支援的即時資料源
儲存類型 | 資料來源類型 | 讀 | 寫 | 維表讀 |
巨量資料儲存 | Apache Hive | 支援 | 支援 | 支援 |
Doris | 支援(flink1.14及flink1.15) | 支援(flink1.14及flink1.15) | 支援 | |
資料湖 | Hudi | 支援 | 支援 | - |
Iceberg | 支援(僅支援原生DDL方式) | 支援(僅支援原生DDL方式) | - | |
Paimon | 支援 | 支援 | - | |
關係型資料庫 | PolarDB | 支援 | 支援 | - |
Postgres | 支援(支援postgres-cdc) | 支援 | 支援 | |
MySQL | 支援(支援mysql-cdc) | 支援 | 支援 | |
SQL Server | 支援(支援sql server-cdc) | - | - | |
Oracle | 支援(支援oracle-cdc) | 支援 | - | |
OCEAN BASE | 支援(支援oceanbase-cdc) | - | - | |
TIDB | 支援(支援tidb-cdc) | - | - | |
ClickHouse | - | 支援(僅Flink 1.15) | - | |
SAP HANA | 支援 | - | - | |
訊息佇列 | Log Service(SLS/LOG_HUB) | 支援(僅flink 1.15) | 支援(僅flink 1.15) | - |
Kafka | 支援 | 支援 | - | |
RabbitMQ | 支援 | 支援 | 不支援 | |
NoSQL | Elasticsearch | 不支援 | 支援 | 不支援 |
Redis | - | 支援(僅Flink 1.15) | 支援(僅Flink 1.15) | |
Apache HBase | - | 支援 | 支援 | |
MongoDB | 支援(支援mongodb-cdc) | - | - | |
StarRocks | 支援 | 支援 | - | |
半結構化儲存 | SAP TABLE | 支援 | 不支援 | 不支援 |
檔案 | OSS | 不支援 | 支援 | 不支援 |
FusionInsight Flink支援的即時資料源
儲存類型 | 資料來源類型 | 讀 | 寫 | 維表讀 |
巨量資料儲存 | Apache Hive | 支援 | 支援 | 支援 |
Doris | 支援 | 支援 | - | |
Paimon | 支援 | 支援 | - | |
資料湖 | Hudi | 支援 | 支援 | - |
關係型資料庫 | PolarDB | 支援 | 支援 | - |
AnalyticDB for PostgreSQL 6.0+ | - | - | 支援 | |
Postgres | - | 支援 | 支援 | |
MySQL | - | 支援 | 支援 | |
Oracle | - | 支援 | - | |
ClickHouse | - | 支援 | - | |
訊息佇列 | Log Service(SLS/LOG_HUB) | 支援 | 支援 | - |
Kafka | 支援 | 支援 | - | |
NoSQL | Elasticsearch | - | 支援 | - |
Redis | 支援 | 支援 | - | |
Apache HBase | - | 支援 | 支援 | |
StarRocks | 支援 | 支援 | - |