flink实时数仓(九):增量同步mysql中数据

数据库中配置流表

jdbc工具类

枚举类

CodeEnum

FlowStatusEnum

HBaseStorageModeEnum

配置类bean对象

flink状态类编程

MD5加密

Hbase sink 模板

样例数据

Flow

bean对象

hbase 工具类

根据cannal中的数据解析成hbase数据格式

通用sink