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

[????]

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




----
??:""<16770...@qq.com;
:2019??12??18??(??) 4:03
??:"user-zh"

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

[????]

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


??flatmap??event-time
??kafka

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


??eventTime??





----
??:"LakeShen"

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

[????]

env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...)
env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...);

kafka??Watermark??flatMap()??
flatMap??1-Nkafka??