?????? ????flinksql ????????????????????????

Mon, 14 Sep 2020 02:27:53 -0700 

??????stream????????????????????hop??????????????????????????????


????????????????????
simpleResults.assignTimestampsAndWatermarks(WatermarkStrategy
        .<OrderDetail&gt;forBoundedOutOfOrderness(Duration.ofHours(1))
        .withTimestampAssigner((event, timestamp)-&gt;event.getGmtPaidLong())
        .withIdleness(Duration.ofSeconds(5)));
-------
???? 
??????????processTime????????????????????????????processTime??????????????????????????rowTime????????????????


------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??9??14??(??????) ????5:19
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ????flinksql ????????????????????????



??????????????????????????????????????????????????????????????????????????????????????????????

??????????????????????????????????row 
time????????????????watermark????????????????

?????? <[email protected]&gt; ??2020??9??14?????? ????1:32??????

&gt; 
??????????????????????????????????????http://chuantu.xyz/t6/741/1600061331x-1224481926.jpg
&gt; ????rowTime????????



-- 

Best,
Benchao Li

回复