対応コネクタ - Realtime Compute for Apache Flink - Alibaba Cloud ドキュメントセンター

Realtime Compute for Apache Flink は、Flink SQL と DataStream API を介して外部ストレージを読み書きする、複数のテーブルタイプとコネクタをサポートしています。

テーブルタイプ

Realtime Compute for Apache Flink は、Flink SQL または DataStream API を使用してテーブルを定義し、外部ストレージのデータを読み書きします。Flink SQL は、次のテーブルタイプをサポートしています。

ソーステーブル：データストリームのエントリポイントです。Kafka や MySQL CDC などの外部システムから未加工のイベントデータを継続的に読み取ります。
ディメンション (ルックアップ) テーブル：ユーザー情報や商品情報など、静的または緩やかに変化するディメンションデータを結合してストリーミングデータをエンリッチ化するための参照テーブルです。
シンクテーブル：データ処理の出口です。集計データや結合データなどの結果を、データウェアハウス、データベース、またはメッセージキューなどの宛先システムに書き込みます。

サポートされているコネクタ

リレーショナルデータベース

NoSQL データベース

メッセージキュー

データウェアハウス

データレイク

ログおよびオブジェクトストレージサービス

ツールおよびデバッグ

キー/値および時系列データベース

汎用

コネクタのサポート詳細

コネクタ	Flink SQL			Flink CDC		実行モード	API タイプ	シンクの更新
コネクタ	ソーステーブル	ディメンションテーブル	シンクテーブル	データソース	シンク	実行モード	API タイプ	シンクの更新
MySQL	√	√	√	√	×	ストリーミングモード	SQL、DataStream、Flink CDC	はい
Hologres：リアルタイムデータウェアハウス	√	√	√	×	√	ストリーミングとバッチ	SQL、DataStream、Flink CDC	はい
Kafka	√	×	√	√	√	ストリーミングモード	SQL、DataStream、データインジェスト用YAML	挿入のみをサポート
MaxCompute	√	√	√	×	√	ストリーミングとバッチ	SQL、DataStream、Flink CDC	挿入のみをサポート
Paimon	√	√	√	×	√	ストリーミングとバッチ	SQL と Flink CDC	はい
Log Service	√	×	√	√	×	ストリーミングモード	SQL、DataStream、Flink CDC	挿入のみをサポート
StarRocks	√	√	√	×	√	ストリーミングとバッチ	SQL、DataStream、Flink CDC	はい
DataHub	√	×	√	×	×	ストリーミングとバッチ	SQL と DataStream	挿入のみをサポート
MongoDB	√	√	√	√	×	ストリーミングモード	SQL、DataStream、Flink CDC	はい
JDBC	√	√	√	×	×	ストリーミングとバッチ	SQL	はい
Object Storage Service	√	×	√	×	×	ストリーミングとバッチ	SQL と DataStream	挿入のみをサポート
ApsaraDB RDS for MySQL 説明このコネクタは非推奨となっています。代わりに MySQL コネクタを使用してください。	×	√	√	MySQL コネクタを使用してください。	×	ストリーミングとバッチ	SQL	はい
Message Queue for RocketMQ	√	×	√	×	×	ストリーミングモード	SQL と DataStream	挿入のみをサポート
Lindorm	×	√	√	×	×	ストリーミングモード	SQL	はい
ApsaraDB for Tair (Redis 互換)	×	√	√	×	×	ストリーミングモード	SQL	はい
ApsaraDB for Tair (Enterprise)	×	×	√	×	×	ストリーミングモード	SQL	はい
ApsaraDB for HBase	×	√	√	×	×	ストリーミングモード	SQL	はい
AnalyticDB for MySQL 3.0	√	√	√	×	×	ストリーミングとバッチ	SQL	はい
AnalyticDB for PostgreSQL	×	√	√	×	×	ストリーミングとバッチ	SQL	はい
PolarDB PostgreSQL (Oracle 互換 1.0) (非推奨)	×	×	√	×	×	ストリーミングとバッチ	SQL	はい
アップサート Kafka	√	×	√	×	√	ストリーミングモード	SQL と Flink CDC	はい
Elasticsearch	√	√	√	×	×	ストリーミングとバッチ	SQL と DataStream	はい
ClickHouse コネクタ	×	×	√	×	×	ストリーミングとバッチ	SQL	はい
Tablestore (OTS)	√	√	√	×	×	ストリーミングモード	SQL	はい
SelectDB	×	×	√	×	×	ストリーミングとバッチ	SQL と DataStream	はい
InfluxDB (非推奨)	×	×	√	×	×	ストリーミングモード	SQL	挿入のみをサポート
Postgres CDC (パブリックプレビュー)	√	×	×	√	×	ストリーミングモード	SQL と Flink CDC	N/A
OceanBase (パブリックプレビュー)	√	√	√	×	√	ストリーミングとバッチ	SQL と Flink CDC	はい
Iceberg	√	×	√	×	√	ストリーミングとバッチ	SQL と Flink CDC	はい
Faker コネクタ	√	√	×	×	×	ストリーミングとバッチ	SQL	N/A
Blackhole	×	×	√	×	×	ストリーミングとバッチ	SQL	はい
Datagen	√	×	×	×	×	ストリーミングとバッチ	SQL	N/A
Print	×	×	√	×	√	ストリーミングとバッチ	SQL と Flink CDC	はい
Hudi (非推奨)	√	×	√	×	×	ストリーミングとバッチ	SQL と DataStream	はい