Konektor yang didukung

Jenis tabel

Realtime Compute for Apache Flink mendefinisikan tabel melalui Flink SQL atau DataStream API untuk membaca dari dan menulis ke penyimpanan eksternal. Flink SQL mendukung jenis tabel berikut:

Source table: Titik masuk aliran data yang secara terus-menerus membaca data event mentah dari sistem eksternal seperti Kafka atau MySQL CDC.
Dimension (lookup) table: Tabel referensi yang memperkaya data streaming dengan melakukan join terhadap data dimensi statis atau dimensi yang berubah lambat, seperti detail pengguna atau produk.
Sink table: Titik keluar pemrosesan data yang menulis hasil—seperti data agregasi atau hasil join—ke sistem tujuan seperti gudang data, database, atau antrian pesan.

Relational database

NoSQL database

Message queue

Data warehouse

Data lake

Log and object storage services

Tools and debugging

Key-value and time series databases

General

Detail dukungan konektor

Connector	Flink SQL			Flink CDC		Execution mode	API type	Sink updates
Connector	Source table	Dimension table	Sink table	Data source	Sink	Execution mode	API type	Sink updates
MySQL	√	√	√	√	×	Streaming mode	SQL, DataStream, dan Flink CDC	Ya
Hologres: real-time data warehouse	√	√	√	×	√	Streaming dan batch	SQL, DataStream, dan Flink CDC	Ya
Kafka	√	×	√	√	√	Streaming	SQL, DataStream, dan YAML untuk data ingestion	Hanya insert yang didukung.
MaxCompute	√	√	√	×	√	Streaming dan batch	SQL, DataStream, dan Flink CDC	Hanya insert yang didukung.
Paimon	√	√	√	×	√	Streaming dan batch modes	SQL dan Flink CDC	Ya
Log Service	√	×	√	√	×	Streaming mode	SQL, DataStream, dan Flink CDC	Hanya insert yang didukung.
StarRocks	√	√	√	×	√	Streaming dan batch modes	SQL, DataStream, dan Flink CDC	Ya
DataHub	√	×	√	×	×	Streaming dan batch modes	SQL dan DataStream	Hanya insert yang didukung.
MongoDB	√	√	√	√	×	Streaming mode	SQL, DataStream, dan Flink CDC	Ya
JDBC	√	√	√	×	×	Streaming dan batch modes	SQL	Ya
Object Storage Service	√	×	√	×	×	Streaming dan batch modes	SQL dan DataStream	Hanya insert yang didukung.
ApsaraDB RDS for MySQL Catatan Konektor ini sedang ditinggalkan. Gunakan konektor MySQL sebagai gantinya.	×	√	√	Gunakan konektor MySQL.	×	Streaming dan batch modes	SQL	Ya
Message Queue for RocketMQ	√	×	√	×	×	Streaming mode	SQL dan DataStream	Hanya insert yang didukung.
Lindorm	×	√	√	×	×	Streaming mode	SQL	Ya
ApsaraDB for Tair (Redis-compatible)	×	√	√	×	×	Streaming mode	SQL	Ya
ApsaraDB for Tair (Enterprise)	×	×	√	×	×	Streaming mode	SQL	Ya
ApsaraDB for HBase	×	√	√	×	×	Streaming mode	SQL	Ya
AnalyticDB for MySQL 3.0	√	√	√	×	×	Streaming dan batch modes	SQL	Ya
AnalyticDB for PostgreSQL	×	√	√	×	×	Streaming dan batch modes	SQL	Ya
PolarDB PostgreSQL (Oracle Compatible 1.0) (deprecating)	×	×	√	×	×	Streaming dan batch modes	SQL	Ya
Upsert Kafka	√	×	√	×	√	Streaming mode	SQL dan Flink CDC	Ya
Elasticsearch	√	√	√	×	×	Streaming dan batch modes	SQL dan DataStream	Ya
ClickHouse connector	×	×	√	×	×	Streaming dan batch modes	SQL	Ya
Tablestore (OTS)	√	√	√	×	×	Streaming mode	SQL	Ya
SelectDB	×	×	√	×	×	Streaming dan batch modes	SQL dan DataStream	Ya
InfluxDB (deprecating)	×	×	√	×	×	Streaming mode	SQL	Hanya insert yang didukung.
Postgres CDC (public preview)	√	×	×	√	×	Streaming mode	SQL dan Flink CDC	N/A
OceanBase (public preview)	√	√	√	×	√	Streaming dan batch modes	SQL dan Flink CDC	Ya
Iceberg	√	×	√	×	√	Streaming dan batch modes	SQL dan Flink CDC	Ya
Faker connector	√	√	×	×	×	Streaming dan batch modes	SQL	N/A
Blackhole	×	×	√	×	×	Streaming dan batch modes	SQL	Ya
Datagen	√	×	×	×	×	Streaming dan batch modes	SQL	N/A
Print	×	×	√	×	√	Streaming dan batch modes	SQL dan Flink CDC	Ya
Hudi (deprecating)	√	×	√	×	×	Streaming dan batch modes	SQL dan DataStream	Ya