任务类型 |
表类型 |
Flink 1.10 |
Flink 1.12 |
实时采集 |
来源 |
Mysql
PolarDB for MySQL8
Oracle
SQLserver
PostgreSQL
DB2
Greenplum
Kafka
EMQ
WebSocket
Socket
Restful
TBDS_Kafka
|
Mysql
PolarDB for MySQL8
Oracle
SQLserver
PostgreSQL
DB2
Greenplum
Kafka
EMQ
WebSocket
Socket
Restful
UPDRDB
|
目标 |
Kafka
Hive
HDFS
|
Kafka
Hive
HDFS
|
FlinkSQL |
源表 |
kafka
TBDS_Kafka
|
kafka
|
维表 |
Mysql
PolarDB for MySQL8
Oracle
SQLserver
PostgreSQL
KingbaseES8
Impala
Clickhouse
TiDB
Kudu
Hbase
ES5.X、6.X、7.X
MongoDB
Redis
TBDS_Hbase
|
Mysql
Oracle
SQLserver
PostgreSQL
KingbaseES8
Clickhouse
Kudu
Inceptor
Hbase
ES5.X、6.X、7.X
MongoDB
Redis
UPRedis
|
结果表 |
Mysql
PolarDB for MySQL8
Oracle
SQLserver
PostgreSQL
KingbaseES8
S3
Impala
Clickhouse
TiDB
Kudu
Hbase
ES5.X、6.X、7.X
MongoDB
Redis
Solr
Kafka
TBDS_Hbase
TBDS_Kafka
|
Mysql
Oracle
SQLserver
PostgreSQL
KingbaseES8
Hive2.x
Clickhouse
Kudu
Inceptor
Hbase
ES5.X、6.X、7.X
MongoDB
Redis
Solr
Kafka
UPRedis
|