订单Topic:order

扫描Topic:scan

揽收率流程图

fliter(collect)

orderEventStream

scanEventStream

connect

scanstate

orderstate

unmatchedOrder(3)

processedStream(匹配成功输出)

matched Order(1)

matchedScan(2)

amountOrder

获取前一天18点-----当天时间24点

时间窗口,过滤当前订单时间

获得揽收率。存入hbase

定义时间窗口(每一天

输出一次数据)

去重

开始随便写写...

揽收流程分析

揽收流程分析

2020-01-16 15:48:34 0 11
这里是评论

相关推荐