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

このトピックでは、Realtime Compute for Apache Flink でサポートされているテーブルタイプとコネクタについて説明します。

テーブルタイプ

Realtime Compute for Apache Flink は Flink SQL を使用して、アップストリームおよびダウンストリームのストレージにマッピングするテーブルを定義します。また、Datastream API を使用してストレージに接続し、読み取りおよび書き込み操作を実行することもできます。以下の Flink SQL テーブルタイプがサポートされています。

ソーステーブル：データストリームのエントリポイントです。Kafka や MySQL CDC などの外部システムから生のイベントデータを継続的に読み取ります。
ディメンション (ルックアップ) テーブル：ストリーミングデータをエンリッチ化するために使用される参照テーブルです。通常、JOIN 操作を使用して、ユーザーやプロダクトの詳細など、静的または更新頻度の低いディメンション情報を関連付けます。
シンクテーブル：データ処理の出口です。集計または結合されたデータなどの計算結果を、データウェアハウス、データベース、またはメッセージキューなどの送信先システムに書き込みます。

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

NoSQL データベース

メッセージキュー

データウェアハウス

データレイク

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

ツールとデバッグ

キーバリューおよび時系列データベース

全般

コネクタのサポート詳細

コネクタ	Flink SQL			Flink CDC		実行モード	API タイプ	シンクの更新
コネクタ	ソーステーブル	ディメンションテーブル	シンクテーブル	データソース	シンク	実行モード	API タイプ	シンクの更新
MySQL	√	√	√	√	×	ストリーミングモード	SQL、DataStream、および Flink CDC	はい
Hologres	√	√	√	×	√	ストリーミングおよびバッチ	SQL、DataStream、および Flink CDC	はい
Message Queue for 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-compatible)	×	√	√	×	×	ストリーミングモード	SQL	はい
ApsaraDB for Tair (Enterprise)	×	×	√	×	×	ストリーミングモード	SQL	はい
ApsaraDB for HBase	×	√	√	×	×	ストリーミングモード	SQL	はい
AnalyticDB for MySQL 3.0	√	√	√	×	×	ストリーミングおよびバッチモード	SQL	はい
AnalyticDB for PostgreSQL	×	√	√	×	×	ストリーミングおよびバッチモード	SQL	はい
PolarDB PostgreSQL (Oracle Compatible 1.0) (非推奨)	×	×	√	×	×	ストリーミングおよびバッチモード	SQL	はい
Upsert 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	はい