Konektor yang didukung - Realtime Compute for Apache Flink

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

Memahami jenis tabel

Realtime Compute for Apache Flink mendukung Flink SQL untuk mendefinisikan tabel yang memetakan ke penyimpanan hulu dan hilir. Sebagai alternatif, Anda dapat menggunakan API DataStream untuk operasi baca dan tulis. Jenis tabel Flink SQL berikut ini didukung:

Source table: Titik masuk aliran data yang terus-menerus membaca data event mentah dari sistem eksternal seperti Kafka atau MySQL CDC.
Dimension table: Tabel referensi yang digunakan untuk memperkaya data streaming dengan informasi statis atau jarang diperbarui, seperti detail pengguna atau produk.
Sink table: Titik keluar pemrosesan data yang menulis hasil—misalnya, data agregat atau hasil join—ke sistem tujuan seperti gudang data, database, atau antrian pesan.

Ikhtisar konektor yang didukung

Database relasional

Database NoSQL

Antrian pesan

Gudang data

Danau data

Layanan penyimpanan log dan objek

Alat dan debugging

Database key-value dan deret waktu

Umum

Rincian konektor yang didukung

Konektor	Jenis tabel yang didukung			Mode eksekusi	Jenis API	Mendukung pembaruan atau penghapusan data tabel sink
Konektor	Source table	Dimension table	Sink table	Mode eksekusi	Jenis API	Mendukung pembaruan atau penghapusan data tabel sink
MySQL Catatan Mendukung koneksi ke ApsaraDB RDS for MySQL, PolarDB for MySQL, dan self-managed MySQL.	√	√	√	Streaming	SQL, DataStream, dan YAML untuk Ingesti Data	Ya
Hologres	√	√	√	Streaming dan batch	SQL, DataStream, dan YAML untuk Ingesti Data	Ya
Kafka	√	×	√	Streaming	SQL, DataStream, dan YAML untuk Ingesti Data	Tidak. Hanya mendukung penyisipan data.
MaxCompute	√	√	√	Streaming dan batch	SQL dan DataStream	Tidak. Hanya mendukung penyisipan data.
Paimon	√	√	√	Streaming dan batch	SQL dan YAML untuk Ingesti Data	Ya
SLS	√	×	√	Streaming	SQL dan DataStream	Tidak. Hanya mendukung penyisipan data.
StarRocks	√	√	√	Streaming dan batch	SQL, DataStream, dan YAML untuk Ingesti Data	Ya
DataHub	√	×	√	Streaming dan batch	SQL dan DataStream	Tidak. Hanya mendukung penyisipan data.
MongoDB	√	√	√	Streaming	SQL dan DataStream	Ya
JDBC	√	√	√	Streaming dan batch	SQL	Ya
OSS	√	×	√	Streaming dan batch	SQL dan DataStream	Tidak. Hanya mendukung penyisipan data.
ApsaraDB RDS for MySQL Catatan Konektor ApsaraDB RDS for MySQL tidak akan lagi didukung. Gunakan konektor MySQL sebagai gantinya.	×	√	√	Streaming dan batch	SQL	Ya
ApsaraMQ for RocketMQ	√	×	√	Streaming	SQL dan DataStream	Tidak. Hanya mendukung penyisipan data.
Lindorm	×	√	√	Streaming	SQL	Ya
Tair (Redis OSS-compatible)	×	√	√	Streaming	SQL	Ya
Tair connector	×	×	√	Streaming	SQL	Ya
ApsaraDB for HBase	×	√	√	Streaming	SQL	Ya
AnalyticDB for MySQL 3.0	√	√	√	Streaming dan batch	SQL	Ya
AnalyticDB for PostgreSQL	×	√	√	Streaming dan batch	SQL	Ya
PolarDB for PostgreSQL (Compatible with Oracle) 1.0 connector	×	×	√	Streaming dan batch	SQL	Ya
Upsert Kafka	√	×	√	Streaming	SQL dan YAML untuk Ingesti Data	Ya
Elasticsearch	√	√	√	Streaming dan batch	SQL dan DataStream	Ya
ClickHouse	×	×	√	Streaming dan batch	SQL	Ya
Tablestore (OTS)	√	√	√	Mode streaming	SQL	Ya
SelectDB	×	×	√	Streaming dan batch	DataStream dan SQL	Ya
InfluxDB	×	×	√	Streaming	SQL	Tidak
Postgres CDC (Pratinjau Publik)	√	×	×	Streaming	SQL	T/A
OceanBase (pratinjau publik)	√	√	√	Streaming dan batch	SQL	Ya
Milvus (pratinjau publik)	×	×	√	Streaming	SQL	Ya
Iceberg	√	×	√	Streaming dan batch	SQL	Ya
Faker	√	√	×	Streaming dan batch	SQL	T/A
Blackhole	×	×	√	Streaming dan batch	SQL	Ya
Datagen	√	×	×	Streaming dan batch	SQL	T/A
Print	×	×	√	Streaming dan batch	SQL dan YAML untuk Ingesti Data	Ya
Hudi (Sedang ditinggalkan)	√	×	√	Streaming dan batch	SQL dan DataStream	Ya