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

Wed, 18 Dec 2019 00:04:51 -0800 

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


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

????????????????????????????????????????eventTime??????????????????kafka??????????????
??????????????????????????
 env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...)
 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??????????????

回复