flink實時數倉(九):增量同步mysql中資料

資料庫中配置流表

jdbc工具類

枚舉類

CodeEnum

FlowStatusEnum

HBaseStorageModeEnum

配置類bean對象

flink狀态類程式設計

MD5加密

Hbase sink 模闆

樣例資料

Flow

bean對象

hbase 工具類

根據cannal中的資料解析成hbase資料格式

通用sink