AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
流程图
2022-07-15 17:39:08
46
举报
分享方式
免费使用
流程图描述
流程图
模板推荐
作者其他创作
大纲/内容
打开OceanbaseCDC的inputFormat
通过Flinkx的OceanbaseCDC-connector
初始化失败
查找元数据，完善空值的header，按照RowData的结构进行LightRecord的转换和组装，字段映射为Flink的type。
加载liboblog动态库（.so，.h，.a文件）
配置、启动Oceanbase实时采集任务
是否需要考虑三次失败连接之后，捕获3次心跳任务失败？
可以传入配置文件路径或者配置文件map和采集起点时间戳（这里我们会采用map的方式）
轮询读取OceanbaseCDC的日志，用com.alipay.light.record.LightRecord类接收。
定义本地方法类和libolog.h中提供的接口映射比如：init，read，release，destory等方法
调用初始化方法init方法
抛出异常，任务结束
过滤type类型为UPDATE|INSERT|DELETE的日志数据
处理结束，等待输出到下游
入口
初始化成功
收藏
立即使用
流程图
收藏
立即使用
trino流程图发布
135974_PO
职业：暂无
去主页
Collect
Get Started
订货流程图
Collect
Get Started
正常结款流程图
Collect
Get Started
业务流程图
Collect
Get Started
流程图-仓储管理WMS业务总体流程图
评论
0
条评论
下一页
Document
