流程图
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的日志数据
处理结束，等待输出到下游
入口
初始化成功
收藏
收藏
0 条评论
下一页
