2020-04-01 10:05:00.0
(2)右流
物流表(shipments)
shipId orderId status shiptime
0 1 shipped...2020-04-01 12:00:00.0
3 4 shipped 2020-04-01 11:30:00.0
1.2 join
(1)代码
//延迟...,1585710000000)、(3,4,shipped,1585711800000) 同窗口,
并在物流表中流(3,4,shipped,1585711800000)输入时,窗口的WM为17(hour)...输出结果:
Window 4hour
(1,iphone,shipped,1585706400000,1585710000000)
(4,pad,shipped,1585706700000,1585711800000...输出结果:
(1,iphone,shipped,1585706400000,1585710000000)
(4,pad,shipped,1585706700000,1585711800000)
(3,huawei