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

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

テーブルタイプの定義

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

ソーステーブル: データストリームのエントリポイントです。Kafka や MySQL CDC などの外部システムから生のイベントデータを継続的に読み取ります。
ディメンションテーブル: データをエンリッチするために使用される参照テーブルです。通常、データストリームと結合して、ユーザーや製品の詳細など、静的またはまれにしか更新されないディメンション情報を追加します。
結果テーブル: データ処理の出口です。集計または結合されたデータなどの計算結果を宛先システムに書き込みます。宛先システムの例としては、データウェアハウス、データベース、メッセージキューなどがあります。

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

NoSQL データベース

メッセージキュー

データウェアハウス

データレイク

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

ツールとデバッグ

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

一般

コネクタのサポート

コネクタ	サポートされているタイプ			実行モード	API タイプ	結果テーブルデータへの更新または削除のサポート
コネクタ	ソーステーブル	ディメンションテーブル	シンクテーブル	実行モード	API タイプ	結果テーブルデータへの更新または削除のサポート
MySQL 説明 ApsaraDB RDS for MySQL、PolarDB for MySQL、および自己管理 MySQL への接続をサポートします。	√	√	√	ストリーミングモード	SQL、DataStream、およびデータインジェスト用の YAML	はい
Hologres	√	√	√	ストリーミングおよびバッチモード	SQL、DataStream、およびデータインジェスト用の YAML	はい
Kafka	√	×	√	ストリーミングモード	SQL、DataStream、およびデータインジェスト用の YAML	結果テーブル内のデータの更新または削除はサポートされていません。データの挿入のみをサポートします。
MaxCompute	√	√	√	ストリーミングおよびバッチモード	SQL および DataStream	結果テーブル内のデータの更新または削除はサポートされていません。データの挿入のみをサポートします。
Paimon	√	√	√	ストリーミングおよびバッチモード	SQL およびデータインジェスト用の YAML	はい
SLS	√	×	√	ストリーミングモード	SQL および DataStream	結果テーブル内のデータの更新または削除はサポートされていません。データの挿入のみをサポートします。
StarRocks	√	√	√	ストリーミングおよびバッチモード	SQL、DataStream、およびデータインジェスト用の YAML	はい
DataHub	√	×	√	ストリーミングおよびバッチモード	SQL および DataStream	結果テーブル内のデータの更新または削除はサポートされていません。データの挿入のみをサポートします。
MongoDB	√	√	√	ストリーミングモード	SQL および DataStream	はい
JDBC	√	√	√	ストリーミングおよびバッチモード	SQL	はい
Object Storage Service (OSS)	√	×	√	ストリーミングおよびバッチモード	SQL および DataStream	結果テーブル内のデータの更新または削除はサポートされていません。データの挿入のみをサポートします。
ApsaraDB RDS for MySQL 説明 ApsaraDB RDS for MySQL コネクタはサポートされなくなります。代わりに MySQL コネクタを使用してください。	×	√	√	ストリーミングおよびバッチモード	SQL	はい
ApsaraMQ for RocketMQ	√	×	√	ストリーミングモード	SQL および DataStream	結果テーブル内のデータの更新または削除はサポートされていません。データの挿入のみをサポートします。
Lindorm	×	√	√	ストリーミングモード	SQL	はい
Tair (Redis Community Edition)	×	√	√	ストリーミングモード	SQL	はい
Tair (Tair Enterprise Edition)	×	×	√	ストリーミングモード	SQL	はい
ApsaraDB for HBase	×	√	√	ストリーミングモード	SQL	はい
AnalyticDB for MySQL 3.0	√	√	√	ストリーミングおよびバッチモード	SQL	はい
AnalyticDB for PostgreSQL (ADB PG)	×	√	√	ストリーミングおよびバッチモード	SQL	はい
PolarDB for PostgreSQL (Oracle Compatible 1.0)	×	×	√	ストリーミングおよびバッチモード	SQL	はい
Upsert Kafka	√	×	√	ストリーミングモード	SQL およびデータインジェスト用の YAML	はい
Elasticsearch	√	√	√	ストリーミングおよびバッチモード	SQL および DataStream	はい
ClickHouse	×	×	√	ストリーミングおよびバッチモード	SQL	はい
Tablestore (OTS)	√	√	√	ストリーミングモード	SQL	はい
SelectDB	×	×	√	ストリーミングおよびバッチモード	DataStream および SQL	はい
InfluxDB	×	×	√	ストリーミングモード	SQL	いいえ
Postgres CDC (パブリックプレビュー)	√	×	×	ストリーミングモード	SQL	該当なし
OceanBase (パブリックプレビュー)	√	√	√	ストリーミングおよびバッチモード	SQL	はい
Iceberg	√	×	√	ストリーミングおよびバッチモード	SQL	はい
Faker	√	√	×	ストリーミングおよびバッチモード	SQL	該当なし
Blackhole	×	×	√	ストリーミングおよびバッチモード	SQL	はい
Datagen	√	×	×	ストリーミングおよびバッチモード	SQL	該当なし
Print	×	×	√	ストリーミングおよびバッチモード	SQL およびデータインジェスト用の YAML	はい
Hudi (非推奨)	√	×	√	ストリーミングおよびバッチモード	SQL および DataStream	はい