???????????????????????????????????????????????????????????? ??????kafka??????????????????????????????event-time?????????????????????????????? ??????????????????????????????????????kafka????????
??????????????????????????????????????????????????????????flatmap??????????????????event-time ??????????kafka???????????????? ????????????????????????????????????????eventTime??????????????????kafka?????????????? ?????????????????????????? env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...) env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...); ??????????????????????????????????????????????????????eventTime?????????????????????????????? ------------------ ???????? ------------------ ??????: "LakeShen"<shenleifight...@gmail.com>; ????????: 2019??12??18??(??????) ????2:10 ??????: "user-zh"<user-zh@flink.apache.org>; ????: Re: ????????????Watermark??flatmap?????????????? flatmap ????????????????????????????????????????watermark ?????????????????????? watermark ?????????????????????? ???? <16770...@qq.com> ??2019??12??18?????? ????9:27?????? > env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...) > > env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...); > > ????kafka??????????????????Watermark??????flatMap()?????????????????????????????????????? > flatMap??????????????????1-N????????????????????????????????kafka??????????????
