Descripción general de los conectores compatibles - Realtime Compute for Apache Flink

Tipos de tablas

Realtime Compute for Apache Flink define las tablas mediante Flink SQL o la API DataStream para leer y escribir en almacenamiento externo. A continuación se muestran los tipos de tablas compatibles con Flink SQL:

Source table: punto de entrada de un flujo de datos. Lee continuamente datos de eventos sin procesar desde sistemas externos como Kafka o MySQL CDC.
Dimension (lookup) table: tabla de referencia que enriquece los datos de streaming al combinarlos con datos de dimensiones estáticos o de cambio lento, como detalles de usuarios o productos.
Sink table: punto de salida del procesamiento de datos. Escribe resultados, como datos agregados o combinados, en un sistema de destino como un almacén de datos, una base de datos o una cola de mensajes.

Conectores compatibles

Base de datos relacional

Base de datos NoSQL

Cola de mensajes

Almacén de datos

Data lake

Servicios de registros y object storage

Herramientas y depuración

Bases de datos de clave-valor y de series temporales

General

Detalles de compatibilidad de los conectores

Conector	Flink SQL			Flink CDC		Modo de ejecución	Tipo de API	Actualizaciones de sink
Conector	Source table	Dimension table	Sink table	Origen de datos	Sink	Modo de ejecución	Tipo de API	Actualizaciones de sink
MySQL SQL connector	√	√	√	√	×	Streaming mode	SQL, DataStream y Flink CDC	Sí
Hologres SQL connector	√	√	√	×	√	Streaming y por lotes	SQL, DataStream y Flink CDC	Sí
Kafka SQL connector	√	×	√	√	√	Streaming	SQL, DataStream y YAML para ingesta de datos	Solo se admiten inserciones.
MaxCompute	√	√	√	×	√	Streaming y por lotes	SQL, DataStream y Flink CDC	Solo se admiten inserciones.
Paimon	√	√	√	×	√	Modos de streaming y por lotes	SQL y Flink CDC	Sí
Log Service	√	×	√	√	×	Streaming mode	SQL, DataStream y Flink CDC	Solo se admiten inserciones.
StarRocks SQL connector	√	√	√	×	√	Modos de streaming y por lotes	SQL, DataStream y Flink CDC	Sí
DataHub	√	×	√	×	×	Modos de streaming y por lotes	SQL y DataStream	Solo se admiten inserciones.
MongoDB	√	√	√	√	×	Streaming mode	SQL, DataStream y Flink CDC	Sí
JDBC	√	√	√	×	×	Modos de streaming y por lotes	SQL	Sí
Object Storage Service	√	×	√	×	×	Modos de streaming y por lotes	SQL y DataStream	Solo se admiten inserciones.
ApsaraDB RDS for MySQL Nota Este conector está en proceso de desaprobación. Use el conector de MySQL en su lugar.	×	√	√	Use el conector de MySQL.	×	Modos de streaming y por lotes	SQL	Sí
Message Queue for RocketMQ	√	×	√	×	×	Streaming mode	SQL y DataStream	Solo se admiten inserciones.
Lindorm	×	√	√	×	×	Streaming mode	SQL	Sí
ApsaraDB for Tair (Redis-compatible)	×	√	√	×	×	Streaming mode	SQL	Sí
ApsaraDB for Tair (Enterprise)	×	×	√	×	×	Streaming mode	SQL	Sí
ApsaraDB for HBase	×	√	√	×	×	Streaming mode	SQL	Sí
AnalyticDB for MySQL 3.0	√	√	√	×	×	Modos de streaming y por lotes	SQL	Sí
AnalyticDB for PostgreSQL	×	√	√	×	×	Modos de streaming y por lotes	SQL	Sí
PolarDB PostgreSQL (Oracle Compatible 1.0) (deprecating)	×	×	√	×	×	Modos de streaming y por lotes	SQL	Sí
Upsert Kafka	√	×	√	×	√	Streaming mode	SQL y Flink CDC	Sí
Elasticsearch	√	√	√	×	×	Modos de streaming y por lotes	SQL y DataStream	Sí
ClickHouse connector	×	×	√	×	×	Modos de streaming y por lotes	SQL	Sí
Tablestore (OTS)	√	√	√	×	×	Streaming mode	SQL	Sí
SelectDB	×	×	√	×	×	Modos de streaming y por lotes	SQL y DataStream	Sí
InfluxDB (deprecating)	×	×	√	×	×	Streaming mode	SQL	Solo se admiten inserciones.
Postgres CDC (public preview)	√	×	×	√	×	Streaming mode	SQL y Flink CDC	N/A
OceanBase (public preview)	√	√	√	×	√	Modos de streaming y por lotes	SQL y Flink CDC	Sí
Iceberg	√	×	√	×	√	Modos de streaming y por lotes	SQL y Flink CDC	Sí
Faker connector	√	√	×	×	×	Modos de streaming y por lotes	SQL	N/A
Blackhole	×	×	√	×	×	Modos de streaming y por lotes	SQL	Sí
Datagen	√	×	×	×	×	Modos de streaming y por lotes	SQL	N/A
Print	×	×	√	×	√	Modos de streaming y por lotes	SQL y Flink CDC	Sí
Hudi (deprecating)	√	×	√	×	×	Modos de streaming y por lotes	SQL y DataStream	Sí