??????????flinksql ??????mysql??????????
Hi?? JOIN??WaterMark??maxoutoforderness ---- ??:"??"<932460...@qq.com; :2020??6??4??(??) 2:15 ??:"user-zh"
??????flink1.9??????????????kafka????????????
Hi: ??prometheuskafka??metricsgrafana?? ---- ??: "Zhonghan Tang"<13122260...@163.com; : 2020??6??3??(??) 2:29 ??: "user-zh"
??????flink sql ??????????????
Hi ??EventTime?? ---- ??:"steven chen"
????Window ProcessFunction????????????
?? window+processfunctionwatermark?? ??inputprocessfunction?? ?? https://www.imageoss.com/image/sTn2U metricrecordsIngt;recordsOut ??window??processfunction??filter?? ?? .window(TumblingEventTimeWindows.of(org.apache.flink.streaming.api.windowing.time.Time.minutes(1))) .process(new ProcessWindowFunction
?????? ????flink??????????????????????
??metricrecordsInrecordsOut ??window??processfunction??filter?? ?? .window(TumblingEventTimeWindows.of(org.apache.flink.streaming.api.windowing.time.Time.minutes(1))) .process(new ProcessWindowFunction
????flink??????????????????????
??flink stream api??ETL 1??tumble??watermark??10s?? topic 5000/s,??topic4000/s processfunction ps
FlinkSQL??????TIMESTAMPDIFF????????E.g??????
buildin Functions??ctrC?? ctrV ?? TIMESTAMPDIFF(DAY, TIMESTAMP time1,TIMESTAMP time2) SQL validate?? ?? TIMESTAMPDIFF(DAY, cast(time1 as timestamp),cast(time2 as timestamp)) TIMESTAMP??
