?????????????????????? ????????????Watermark??flatmap??????????????

Wed, 18 Dec 2019 00:12:52 -0800 

??????????????????github????????
https://github.com/maobuji/Blog/blob/master/image/changeEventTime.jpg




------------------ ???????? ------------------
??????:&nbsp;"????"<[email protected]&gt;;
????????:&nbsp;2019??12??18??(??????) ????4:03
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;?????? ????????????Watermark??flatmap??????????????



????????????????????????????????????????????????????????????
??????kafka??????????????????????????????event-time??????????????????????????????
??????????????????????????????????????kafka????????


??????????????????????????????????????????????????????????flatmap??????????????????event-time
??????????kafka????????????????

????????????????????????????????????????eventTime??????????????????kafka??????????????
??????????????????????????
&nbsp;env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...)
&nbsp;env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...);


??????????????????????????????????????????????????????eventTime??????????????????????????????





------------------ ???????? ------------------
??????:&nbsp;"LakeShen"<[email protected]&gt;;
????????:&nbsp;2019??12??18??(??????) ????2:10
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ????????????Watermark??flatmap??????????????



flatmap ????????????????????????????????????????watermark 
?????????????????????? watermark ??????????????????????

???? <[email protected]&gt; ??2019??12??18?????? ????9:27??????

&gt; env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...)
&gt;
&gt; 
env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...);
&gt;
&gt; 
????kafka??????????????????Watermark??????flatMap()??????????????????????????????????????
&gt; 
flatMap??????????????????1-N????????????????????????????????kafka??????????????

回复