Dataphin のリアルタイムコンピュートエンジンでは、リアルタイムノードを使用してリアルタイムデータソースのテーブルを作成できます。このトピックでは、各 Dataphin リアルタイムコンピュートエンジンがサポートするリアルタイムデータソースと、その読み取りおよび書き込み機能について説明します。
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 | サポート (CDH 6.x Hive 2.1.1、CDP 7.x Hive 3.1.3、AsiaInfo DP 5.x Hive 3.1.0 のみ) | サポート | サポート | サポート |
Hive (Hudi) | サポート | サポート | サポート | - | |
Hive (Iceberg) | - | サポート (ネイティブ DDL モードのみ) | サポート (ネイティブ DDL モードのみ) | ||
Hive (Paimon) | サポート | サポート | サポート | サポート | |
Hudi | サポート | サポート | サポート | - | |
Doris | サポート | サポート (flink 1.14 および flink 1.15) | サポート (flink 1.14 および flink 1.15) | サポート | |
SelectDB | - | - | サポート | - | |
Paimon | サポート | サポート (Flink 1.14 および Flink 1.15) | サポート (Flink 1.14 および Flink 1.15) | - | |
StarRocks | サポート | サポート | サポート | - | |
TDH Inceptor (9.3.x) | サポート | - | サポート | サポート | |
MySQL | サポート | サポート (CDC) | サポート | サポート | |
SAP HANA | サポート | サポート | - | - | |
Microsoft SQL Server | サポート | サポート (CDC) | - | - | |
PostgreSQL | サポート | サポート | サポート | サポート | |
AnalyticDB for PostgreSQL | サポート | - | サポート | - | |
OceanBase | サポート | サポート (CDC) | |||
Oracle | サポート | サポート (CDC) | サポート | - | |
ClickHouse | サポート | - | サポート (Flink 1.15 のみ) | - | |
TiDB | サポート | サポート (CDC) | - | - | |
GaussDB (DWS) | - | - | サポート | サポート | |
メッセージキュー | Log Service | サポート | サポート (flink 1.15 のみ) | サポート (flink 1.15 のみ) | - |
Kafka | サポート | サポート | サポート | - | |
RabbitMQ | サポート | サポート | サポート | - | |
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) | サポート (Java Database Connectivity (JDBC)) | サポート (JDBC) |
PostgreSQL | - | サポート (JDBC) | サポート (JDBC) | |
Oracle | - | サポート (JDBC) | サポート (JDBC) | |
メッセージキュー | Kafka | サポート | サポート | - |