流程图梳理
2022-12-15 16:38:02 0 举报流程梳理
作者其他创作
大纲/内容
select * from flink_job_kafka_consumer_cfg where xxxx
map/window
oracle（核心，ECF）
ES
Stream
map/filter
Es
databaseSource
配置信息
FlinkKafkaconsumer
(172.32.5.95:1521/oracledb)oracle
异步IO
database
Driver
四，从数据库读取数据和oracle异步关联写入es以CustDepMdmAsstApp为例
二，写入es，以AcctReplApp为例，(更换账号）
FinkKafkaconsumer
impala(B中心)
一，存在异步的情况（核心，ECF）
databasesSource
oracle
收藏
职业：暂无
0 条评论
下一页
