??????????????????????"??????"????????????????????????????????????????????UV?? sink?????????? tm uv 2020/06/17 13:46:00 10000 2020/06/17 13:47:00 20000 2020/06/17 13:48:00 30000
group by ?????????????????????? ------------------ ???????? ------------------ ??????: "Benchao Li"<[email protected]>; ????????: 2020??6??17??(??????) ????11:46 ??????: "user-zh"<[email protected]>; ????: Re: ??????FLINKSQL1.10????????????UV Hi?? ?????????????????????????????? 1. ??????????group by + mini batch 2. window???? + fast emit ????#1??group by????????????????????????????????????????????????DATE_FORMAT(rowtm, 'yyyy-MM-dd')?? ??????????????????????????????state retention??????????????????????[1] ????????mini batch???????????? ??????[2] ???????? ????#2????????????????????????tumble???????????????????????????????????????????????????? fast emit????????????????????experimental??feature???????????????????????????????????????????????????????????? table.exec.emit.early-fire.enabled = true table.exec.emit.early-fire.delay = 60 s [1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/query_configuration.html [2] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html x <[email protected]> ??2020??6??17?????? ????11:14?????? > ??????????????????????0??????????????UV??????????????????????????????????????UV?????????????????????? > CREATE VIEW uv_per_10min AS > SELECT&nbsp; > &nbsp; MAX(DATE_FORMAT(proctime&nbsp;, 'yyyy-MM-dd HH:mm:00'))&nbsp;OVER w > AS time_str,&nbsp; > &nbsp; COUNT(DISTINCT user_id) OVER w AS uv > FROM user_behavior > WINDOW w AS (ORDER BY proctime ROWS BETWEEN UNBOUNDED PRECEDING AND > CURRENT ROW); > > > ?????????????????????????? > PARTITION BY DATE_FORMAT(rowtm, 'yyyy-MM-dd') ?????????????????????????????????? > PS??1.10??????????DDL??????????CREATE VIEW?? > ????
