【19】Flink 实战案例开发(一):数据清洗1、应用场景分析2、DataClean代码开发3、实践运行
1、应用场景分析数据清洗【实时ETL】数据报表1.1、数据清洗【实时ETL】1.1.1、需求分析针对算法产生的日志数据进行清洗拆分算法产生的日志数据是嵌套大JSON格式(json嵌套json),需要拆分打平针对算法中的国家字段进行大区转换最后把不同类型的日志数据分别进行存储1.1.2、架构图创建一个大的项目,用Maven来维护每个flink需求,即job创建一个...