Supported connectors - Realtime Compute for Apache Flink - Alibaba Cloud Dokümantasyon Merkezi

Realtime Compute for Apache Flink, Flink SQL ve DataStream API aracılığıyla harici depolama alanlarından veri okumak ve bu alanlara veri yazmak için birden çok tablo türü ve bağlayıcıyı destekler.

Tablo türleri

Realtime Compute for Apache Flink, harici depolama alanlarından veri okumak ve bu alanlara veri yazmak amacıyla tabloları Flink SQL veya DataStream API üzerinden tanımlar. Flink SQL aşağıdaki tablo türlerini destekler:

Kaynak tablo: Veri akışının giriş noktasıdır. Kafka veya MySQL CDC gibi harici sistemlerden ham olay verilerini sürekli olarak okur.
Boyut (arama) tablosu: Kullanıcı veya ürün ayrıntıları gibi statik ya da yavaş değişen boyut verileriyle birleştirme yaparak akış verilerini zenginleştiren referans tablodur.
Sink tablo: Veri işlemenin çıkış noktasıdır. Toplanmış veya birleştirilmiş veriler gibi sonuçları bir veri ambarına, veritabanına veya mesaj kuyruğuna yazar.

Desteklenen bağlayıcılar

İlişkisel veritabanı

NoSQL veritabanı

Mesaj kuyruğu

Veri ambarı

Veri gölü

Günlük ve nesne depolama hizmetleri

Araçlar ve hata ayıklama

Anahtar-değer ve zaman serisi veritabanları

Genel

Bağlayıcı destek ayrıntıları

Bağlayıcı	Flink SQL			Flink CDC		Çalıştırma modu	API türü	Sink güncellemeleri
Bağlayıcı	Kaynak tablo	Boyut tablosu	Sink tablo	Veri kaynağı	Sink	Çalıştırma modu	API türü	Sink güncellemeleri
MySQL SQL connector	√	√	√	√	×	Akış modu	SQL, DataStream ve Flink CDC	Evet
Hologres SQL connector	√	√	√	×	√	Akış ve toplu iş	SQL, DataStream ve Flink CDC	Evet
Kafka SQL connector	√	×	√	√	√	Akış	Veri alımı için SQL, DataStream ve YAML	Yalnızca ekleme desteklenir.
MaxCompute	√	√	√	×	√	Akış ve toplu iş	SQL, DataStream ve Flink CDC	Yalnızca ekleme desteklenir.
Paimon	√	√	√	×	√	Akış ve toplu iş modları	SQL ve Flink CDC	Evet
Log Service	√	×	√	√	×	Akış modu	SQL, DataStream ve Flink CDC	Yalnızca ekleme desteklenir.
StarRocks SQL connector	√	√	√	×	√	Akış ve toplu iş modları	SQL, DataStream ve Flink CDC	Evet
DataHub	√	×	√	×	×	Akış ve toplu iş modları	SQL ve DataStream	Yalnızca ekleme desteklenir.
MongoDB	√	√	√	√	×	Akış modu	SQL, DataStream ve Flink CDC	Evet
JDBC	√	√	√	×	×	Akış ve toplu iş modları	SQL	Evet
Object Storage Service	√	×	√	×	×	Akış ve toplu iş modları	SQL ve DataStream	Yalnızca ekleme desteklenir.
ApsaraDB RDS for MySQL Not Bu bağlayıcı kullanımdan kaldırılmaktadır. Bunun yerine MySQL bağlayıcısını kullanın.	×	√	√	MySQL bağlayıcısını kullanın.	×	Akış ve toplu iş modları	SQL	Evet
Message Queue for RocketMQ	√	×	√	×	×	Akış modu	SQL ve DataStream	Yalnızca ekleme desteklenir.
Lindorm	×	√	√	×	×	Akış modu	SQL	Evet
ApsaraDB for Tair (Redis uyumlu)	×	√	√	×	×	Akış modu	SQL	Evet
ApsaraDB for Tair (Enterprise)	×	×	√	×	×	Akış modu	SQL	Evet
ApsaraDB for HBase	×	√	√	×	×	Akış modu	SQL	Evet
AnalyticDB for MySQL 3.0	√	√	√	×	×	Akış ve toplu iş modları	SQL	Evet
AnalyticDB for PostgreSQL	×	√	√	×	×	Akış ve toplu iş modları	SQL	Evet
PolarDB PostgreSQL (Oracle Compatible 1.0) (kullanımdan kaldırılıyor)	×	×	√	×	×	Akış ve toplu iş modları	SQL	Evet
Upsert Kafka	√	×	√	×	√	Akış modu	SQL ve Flink CDC	Evet
Elasticsearch	√	√	√	×	×	Akış ve toplu iş modları	SQL ve DataStream	Evet
ClickHouse connector	×	×	√	×	×	Akış ve toplu iş modları	SQL	Evet
Tablestore (OTS)	√	√	√	×	×	Akış modu	SQL	Evet
SelectDB	×	×	√	×	×	Akış ve toplu iş modları	SQL ve DataStream	Evet
InfluxDB (kullanımdan kaldırılıyor)	×	×	√	×	×	Akış modu	SQL	Yalnızca ekleme desteklenir.
Postgres CDC (genel önizleme)	√	×	×	√	×	Akış modu	SQL ve Flink CDC	Yok
OceanBase (genel önizleme)	√	√	√	×	√	Akış ve toplu iş modları	SQL ve Flink CDC	Evet
Iceberg	√	×	√	×	√	Akış ve toplu iş modları	SQL ve Flink CDC	Evet
Faker connector	√	√	×	×	×	Akış ve toplu iş modları	SQL	Yok
Blackhole	×	×	√	×	×	Akış ve toplu iş modları	SQL	Evet
Datagen	√	×	×	×	×	Akış ve toplu iş modları	SQL	Yok
Print	×	×	√	×	√	Akış ve toplu iş modları	SQL ve Flink CDC	Evet
Hudi (kullanımdan kaldırılıyor)	√	×	√	×	×	Akış ve toplu iş modları	SQL ve DataStream	Evet