进行分流操作
11)对原始数据的窗口流数据进行实时故障分析(区分出来告警数据和非告警数据19个告警字段)
12)加载业务中间表(7张表:车辆表、车辆类型表、车辆销售记录表,车俩用途表4张),并进行广播...数据源模型
从MySQL中读取车型车系销售信息
select t12.vin,t12.series_name,t12.model_name,t12.series_code,t12.model_code...,t12.nick_name,t3.sales_date product_date,t4.car_type
from (select t1.vin, t1.series_name, t2.show_name...car_type from vehicle_networking.t_model_car tm) t4
on t12.vin = t4.vin
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传...//加载车辆基础信息表(车辆类型、车辆、销售记录表、车辆用途表)
//重写open方法
//重写run方法
//重写close方法
//重写cancel方法
窗口流数据与广播数据connect再flatMap