Supported connectors - Realtime Compute for Apache Flink - Centre de documentation Alibaba Cloud

Realtime Compute for Apache Flink prend en charge plusieurs types de tables et connecteurs pour lire et écrire dans des systèmes de stockage externes via Flink SQL et l'API DataStream.

Types de table

Realtime Compute for Apache Flink définit des tables à l'aide de Flink SQL ou de l'API DataStream afin de lire et d'écrire dans des systèmes de stockage externes. Flink SQL prend en charge les types de table suivants :

Table source : point d'entrée d'un flux de données. Elle lit en continu les données brutes d'événements provenant de systèmes externes tels que Kafka ou MySQL CDC.
Table de dimension (lookup) : table de référence qui enrichit les données en streaming en effectuant une jointure avec des données de dimension statiques ou évoluant lentement, telles que les détails des utilisateurs ou des produits.
Table de destination (sink) : point de sortie du traitement des données. Elle écrit les résultats, tels que les données agrégées ou jointes, vers un système de destination comme un entrepôt de données, une base de données ou une file d'attente de messages.

Connecteurs pris en charge

Base de données relationnelle

Base de données NoSQL

File d'attente de messages

Entrepôt de données

Data lake

Services de journalisation et de stockage d'objets

Outils et débogage

Bases de données clé-valeur et séries temporelles

Général

Détails de la prise en charge des connecteurs

Connecteur	Flink SQL			Flink CDC		Mode d'exécution	Type d'API	Mises à jour du sink
Connecteur	Table source	Table de dimension	Table de destination	Source de données	Sink	Mode d'exécution	Type d'API	Mises à jour du sink
Connecteur MySQL SQL	√	√	√	√	×	Mode streaming	SQL, DataStream et Flink CDC	Oui
Connecteur Hologres SQL	√	√	√	×	√	Streaming et batch	SQL, DataStream et Flink CDC	Oui
Connecteur Kafka SQL	√	×	√	√	√	Streaming	SQL, DataStream et YAML pour l'ingestion de données	Seules les insertions sont prises en charge.
MaxCompute	√	√	√	×	√	Streaming et batch	SQL, DataStream et Flink CDC	Seules les insertions sont prises en charge.
Paimon	√	√	√	×	√	Modes streaming et batch	SQL et Flink CDC	Oui
Log Service	√	×	√	√	×	Mode streaming	SQL, DataStream et Flink CDC	Seules les insertions sont prises en charge.
Connecteur StarRocks SQL	√	√	√	×	√	Modes streaming et batch	SQL, DataStream et Flink CDC	Oui
DataHub	√	×	√	×	×	Modes streaming et batch	SQL et DataStream	Seules les insertions sont prises en charge.
MongoDB	√	√	√	√	×	Mode streaming	SQL, DataStream et Flink CDC	Oui
JDBC	√	√	√	×	×	Modes streaming et batch	SQL	Oui
Object Storage Service	√	×	√	×	×	Modes streaming et batch	SQL et DataStream	Seules les insertions sont prises en charge.
ApsaraDB RDS for MySQL Remarque Ce connecteur est obsolète. Utilisez le connecteur MySQL à la place.	×	√	√	Utilisez le connecteur MySQL.	×	Modes streaming et batch	SQL	Oui
Message Queue for RocketMQ	√	×	√	×	×	Mode streaming	SQL et DataStream	Seules les insertions sont prises en charge.
Lindorm	×	√	√	×	×	Mode streaming	SQL	Oui
ApsaraDB for Tair (compatible Redis)	×	√	√	×	×	Mode streaming	SQL	Oui
ApsaraDB for Tair (Enterprise)	×	×	√	×	×	Mode streaming	SQL	Oui
ApsaraDB for HBase	×	√	√	×	×	Mode streaming	SQL	Oui
AnalyticDB for MySQL 3.0	√	√	√	×	×	Modes streaming et batch	SQL	Oui
AnalyticDB for PostgreSQL	×	√	√	×	×	Modes streaming et batch	SQL	Oui
PolarDB PostgreSQL (compatible Oracle 1.0) (obsolète)	×	×	√	×	×	Modes streaming et batch	SQL	Oui
Upsert Kafka	√	×	√	×	√	Mode streaming	SQL et Flink CDC	Oui
Elasticsearch	√	√	√	×	×	Modes streaming et batch	SQL et DataStream	Oui
Connecteur ClickHouse	×	×	√	×	×	Modes streaming et batch	SQL	Oui
Tablestore (OTS)	√	√	√	×	×	Mode streaming	SQL	Oui
SelectDB	×	×	√	×	×	Modes streaming et batch	SQL et DataStream	Oui
InfluxDB (obsolète)	×	×	√	×	×	Mode streaming	SQL	Seules les insertions sont prises en charge.
Postgres CDC (aperçu public)	√	×	×	√	×	Mode streaming	SQL et Flink CDC	S.O.
OceanBase (aperçu public)	√	√	√	×	√	Modes streaming et batch	SQL et Flink CDC	Oui
Iceberg	√	×	√	×	√	Modes streaming et batch	SQL et Flink CDC	Oui
Connecteur Faker	√	√	×	×	×	Modes streaming et batch	SQL	S.O.
Blackhole	×	×	√	×	×	Modes streaming et batch	SQL	Oui
Datagen	√	×	×	×	×	Modes streaming et batch	SQL	S.O.
Print	×	×	√	×	√	Modes streaming et batch	SQL et Flink CDC	Oui
Hudi (obsolète)	√	×	√	×	×	Modes streaming et batch	SQL et DataStream	Oui