Conectores suportados

O Realtime Compute for Apache Flink oferece suporte a diversos tipos de tabela e conectores para leitura e gravação em armazenamentos externos por meio do Flink SQL e da DataStream API.

Tipos de tabela

O Realtime Compute for Apache Flink define tabelas via Flink SQL ou DataStream API para ler e gravar dados em sistemas externos. O Flink SQL aceita os seguintes tipos de tabela:

Tabela source: ponto de entrada do fluxo de dados. Lê continuamente eventos brutos de sistemas externos, como Kafka ou MySQL CDC.
Tabela de dimensão (lookup): tabela de referência que enriquece dados em streaming ao associar informações estáticas ou de alteração lenta, como detalhes de usuários ou product.
Tabela sink: destino final do processamento. Grava resultados, como dados agregados ou combinados, em sistemas como data warehouses, bancos de dados ou filas de mensagens.

Banco de dados relacional

Banco de dados NoSQL

Fila de mensagens

Data warehouse

Data lake

Serviços de log e armazenamento de objetos

Ferramentas e depuração

Bancos de dados chave-valor e de séries temporais

Geral

Detalhes do suporte aos conectores

Conector	Flink SQL			Flink CDC		Modo de execução	Tipo de API	Atualizações no sink
Conector	Tabela source	Tabela de dimensão	Tabela sink	Source de dados	Sink	Modo de execução	Tipo de API	Atualizações no sink
MySQL	√	√	√	√	×	Streaming	SQL, DataStream e Flink CDC	Sim
Hologres: real-time data warehouse	√	√	√	×	√	Streaming e batch	SQL, DataStream e Flink CDC	Sim
Kafka	√	×	√	√	√	Streaming	SQL, DataStream e YAML para ingestão de dados	Somente inserções.
MaxCompute	√	√	√	×	√	Streaming e batch	SQL, DataStream e Flink CDC	Somente inserções.
Paimon	√	√	√	×	√	Streaming e batch	SQL e Flink CDC	Sim
Log Service	√	×	√	√	×	Streaming	SQL, DataStream e Flink CDC	Somente inserções.
StarRocks	√	√	√	×	√	Streaming e batch	SQL, DataStream e Flink CDC	Sim
DataHub	√	×	√	×	×	Streaming e batch	SQL e DataStream	Somente inserções.
MongoDB	√	√	√	√	×	Streaming	SQL, DataStream e Flink CDC	Sim
JDBC	√	√	√	×	×	Streaming e batch	SQL	Sim
Object Storage Service	√	×	√	×	×	Streaming e batch	SQL e DataStream	Somente inserções.
ApsaraDB RDS for MySQL Nota Este conector será descontinuado. Use o conector MySQL.	×	√	√	Use o conector MySQL.	×	Streaming e batch	SQL	Sim
Message Queue for RocketMQ	√	×	√	×	×	Streaming	SQL e DataStream	Somente inserções.
Lindorm	×	√	√	×	×	Streaming	SQL	Sim
ApsaraDB for Tair (Redis-compatible)	×	√	√	×	×	Streaming	SQL	Sim
ApsaraDB for Tair (Enterprise)	×	×	√	×	×	Streaming	SQL	Sim
ApsaraDB for HBase	×	√	√	×	×	Streaming	SQL	Sim
AnalyticDB for MySQL 3.0	√	√	√	×	×	Streaming e batch	SQL	Sim
AnalyticDB for PostgreSQL	×	√	√	×	×	Streaming e batch	SQL	Sim
PolarDB PostgreSQL (Oracle Compatible 1.0) (deprecating)	×	×	√	×	×	Streaming e batch	SQL	Sim
Upsert Kafka	√	×	√	×	√	Streaming	SQL e Flink CDC	Sim
Elasticsearch	√	√	√	×	×	Streaming e batch	SQL e DataStream	Sim
ClickHouse connector	×	×	√	×	×	Streaming e batch	SQL	Sim
Tablestore (OTS)	√	√	√	×	×	Streaming	SQL	Sim
SelectDB	×	×	√	×	×	Streaming e batch	SQL e DataStream	Sim
InfluxDB (deprecating)	×	×	√	×	×	Streaming	SQL	Somente inserções.
Postgres CDC (public preview)	√	×	×	√	×	Streaming	SQL e Flink CDC	N/A
OceanBase (public preview)	√	√	√	×	√	Streaming e batch	SQL e Flink CDC	Sim
Iceberg	√	×	√	×	√	Streaming e batch	SQL e Flink CDC	Sim
Faker connector	√	√	×	×	×	Streaming e batch	SQL	N/A
Blackhole	×	×	√	×	×	Streaming e batch	SQL	Sim
Datagen	√	×	×	×	×	Streaming e batch	SQL	N/A
Print	×	×	√	×	√	Streaming e batch	SQL e Flink CDC	Sim
Hudi (deprecating)	√	×	√	×	×	Streaming e batch	SQL e DataStream	Sim