Konektor yang didukung

Topik ini menjelaskan jenis tabel dan konektor yang didukung oleh Realtime Compute for Apache Flink.

Jenis tabel

Realtime Compute for Apache Flink menggunakan Flink SQL untuk mendefinisikan tabel yang dipetakan ke penyimpanan hulu dan hilir. Anda juga dapat menggunakan Datastream API untuk terhubung ke penyimpanan serta melakukan operasi baca dan tulis. Jenis tabel Flink SQL berikut ini didukung:

Source table: Titik masuk aliran data. Tabel ini secara terus-menerus membaca data event mentah dari sistem eksternal, seperti Kafka atau MySQL CDC.
Dimension (lookup) table: Tabel referensi yang digunakan untuk memperkaya data streaming. Tabel ini biasanya dikaitkan melalui operasi JOIN dengan informasi dimensi statis atau yang jarang diperbarui, seperti detail pengguna atau produk.
Sink table: Titik keluar pemrosesan data. Tabel ini menulis hasil komputasi—seperti data agregat 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	√	√	√	×	√	Streaming dan batch	SQL, DataStream, dan Flink CDC	Ya
Message Queue for Kafka	√	×	√	√	√	Streaming	SQL, DataStream, dan YAML untuk ingesti data	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 dihentikan. 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	×	×	√	×	×	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	√	√	×	×	×	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