Dataphin のリアルタイムコンピューティングエンジンでは、リアルタイムノードを使用してリアルタイムデータソースのテーブルを作成できます。このトピックでは、各 Dataphin リアルタイムコンピューティングエンジンがサポートするリアルタイムデータソースと、それらの読み取りおよび書き込み機能について説明します。
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 | サポート (flink 1.14 および flink 1.15) | サポート (flink 1.14 および flink 1.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 | サポート | サポート | - |