?????? ??????FLINKSQL1.10????????????UV

x Mon, 06 Jul 2020 19:47:49 -0700

??blinkval setttings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()






------------------&nbsp;????????&nbsp;------------------
??????:&nbsp;"Benchao Li"<[email protected]&gt;;
????????:&nbsp;2020??7??6??(??????) ????11:11
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ??????FLINKSQL1.10????????????UV



????????????????????????????????blink planner????

x <[email protected]&gt; ??2020??7??6?????? ????1:24??????

&gt; sorry,????????????????????????group agg.
&gt;
&gt; 
????????tableConfig.setIdleStateRetentionTime(Time.minutes(2),Time.minutes(7))??????????????????????????????????????????????.
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:&amp;nbsp;"Benchao Li"<[email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??7??6??(??????) ????12:52
&gt; ??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: ??????FLINKSQL1.10????????????UV
&gt;
&gt;
&gt;
&gt; ????????SQL??????????????????????????????????????????
&gt; ??????????????????????state 
retention[1]??????????????????????????????????????
&gt;
&gt; [1]
&gt;
&gt; 
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/query_configuration.html#idle-state-retention-time
&gt;
&gt; x <[email protected]&amp;gt; ??2020??7??6?????? ????11:15??????
&gt;
&gt; &amp;gt; ??????1.10.1??????sink????????????????window??????count
&gt; &amp;gt; distinct??????????????????????????????????window??????count
&gt; &amp;gt;
&gt; 
distinct??????????????????????????????????????????????window????????????????group&amp;amp;nbsp;DATE_FORMAT(rowtm,
&gt; &amp;gt; 'yyyy-MM-dd') ????sql??????????????????????????
&gt; &amp;gt; val rt_totaluv_view : Table = tabEnv.sqlQuery(
&gt; &amp;gt;&amp;nbsp;&amp;nbsp; """
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; SELECT 
MAX(DATE_FORMAT(rowtm, 'yyyy-MM-dd
&gt; HH:mm:00'))
&gt; &amp;gt; time_str,COUNT(DISTINCT userkey) uv
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; FROM source
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; GROUP BY 
DATE_FORMAT(rowtm, 'yyyy-MM-dd')
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; """)
&gt; &amp;gt; tabEnv.createTemporaryView("rt_totaluv_view",rt_totaluv_view)
&gt; &amp;gt;
&gt; &amp;gt; val totaluvTmp =
&gt; tabEnv.toRetractStream[(String,Long)](rt_totaluv_view)
&gt; &amp;gt;&amp;nbsp;&amp;nbsp; .filter( line =&amp;amp;gt; line._1 == true 
).map( line
&gt; =&amp;amp;gt; line._2 )
&gt; &amp;gt;
&gt; &amp;gt; val totaluvTabTmp = tabEnv.fromDataStream( totaluvTmp )
&gt; &amp;gt;
&gt; &amp;gt; tabEnv.sqlUpdate(
&gt; &amp;gt;&amp;nbsp;&amp;nbsp; s"""
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; INSERT INTO mysql_totaluv
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; SELECT _1,MAX(_2)
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; FROM $totaluvTabTmp
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; GROUP BY _1
&gt; &amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; """)
&gt; &amp;gt; 
------------------&amp;amp;nbsp;????????&amp;amp;nbsp;------------------
&gt; &amp;gt; ??????:&amp;amp;nbsp;"Benchao 
Li"<[email protected]&amp;amp;gt;;
&gt; &amp;gt; ????????:&amp;amp;nbsp;2020??7??3??(??????) ????9:47
&gt; &amp;gt; 
??????:&amp;amp;nbsp;"user-zh"<[email protected]&amp;amp;gt;;
&gt; &amp;gt;
&gt; &amp;gt; ????:&amp;amp;nbsp;Re: ??????FLINKSQL1.10????????????UV
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 
??????????????????????????????????????????[1]??????window??????count 
distinct??????????????
&gt; &amp;gt; ??????????1.11??????????
&gt; &amp;gt;
&gt; &amp;gt; [1] https://issues.apache.org/jira/browse/FLINK-17942
&gt; &amp;gt;
&gt; &amp;gt; x <[email protected]&amp;amp;gt; ??2020??7??3?????? ????4:34??????
&gt; &amp;gt;
&gt; &amp;gt; &amp;amp;gt; 
????????????????????????????????checkpoint??????????????????????????????????
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt;
&gt; 
????????tableConfig.setIdleStateRetentionTime(Time.minutes(2),Time.minutes(7)),??????????????????????key????????????????????????????
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; 
------------------&amp;amp;amp;nbsp;????????&amp;amp;amp;nbsp;------------------
&gt; &amp;gt; &amp;amp;gt; ??????:&amp;amp;amp;nbsp;"Jark 
Wu"<[email protected]&amp;amp;amp;gt;;
&gt; &amp;gt; &amp;amp;gt; ????????:&amp;amp;amp;nbsp;2020??6??18??(??????) 
????12:16
&gt; &amp;gt; &amp;amp;gt; 
??????:&amp;amp;amp;nbsp;"user-zh"<[email protected]
&gt; &amp;amp;amp;gt;;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; ????:&amp;amp;amp;nbsp;Re: 
??????FLINKSQL1.10????????????UV
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; ??????????????????????????????
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; On Thu, 18 Jun 2020 at 10:34, x 
<[email protected]&amp;amp;amp;gt;
&gt; wrote:
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
??????1.10??????????????????,???????????????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; val resTmpTab: Table = 
tabEnv.sqlQuery(
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp; 
"""
&gt; &amp;gt; &amp;amp;gt;
&gt; 
&amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;
 SELECT
&gt; &amp;gt; MAX(DATE_FORMAT(ts, 'yyyy-MM-dd
&gt; &amp;gt; &amp;amp;gt; HH:mm:00'))
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; time_str,COUNT(DISTINCT userkey) uv
&gt; &amp;gt; &amp;amp;gt;
&gt; 
&amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;
 FROM
&gt; &amp;gt; 
user_behavior&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp; GROUP BY
&gt; &amp;gt; &amp;amp;gt; DATE_FORMAT(ts,
&gt; 'yyyy-MM-dd')&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp; """)
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; val
&gt; &amp;gt; resTmpStream=tabEnv.toRetractStream[(String,Long)](resTmpTab)
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;
&gt; &amp;gt; &amp;amp;gt;
&gt; 
.filter(line=&amp;amp;amp;amp;gt;line._1==true).map(line=&amp;amp;amp;amp;gt;line._2)
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; val res= 
tabEnv.fromDataStream(resTmpStream)
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; tabEnv.sqlUpdate(
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp; 
s"""
&gt; &amp;gt; &amp;amp;gt;
&gt; 
&amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;
 INSERT
&gt; INTO
&gt; &amp;gt; rt_totaluv
&gt; &amp;gt; &amp;amp;gt;
&gt; 
&amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;
 SELECT
&gt; _1,MAX(_2)
&gt; &amp;gt; &amp;amp;gt;
&gt; 
&amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;
 FROM
&gt; $res
&gt; &amp;gt; &amp;amp;gt;
&gt; 
&amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;
 GROUP
&gt; BY _1
&gt; &amp;gt; &amp;amp;gt;
&gt; 
&amp;amp;amp;gt;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;&amp;amp;amp;nbsp;
 """)
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt;
&gt; 
------------------&amp;amp;amp;amp;nbsp;????????&amp;amp;amp;amp;nbsp;------------------
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; ??????:&amp;amp;amp;amp;nbsp;"Jark 
Wu"<
&gt; [email protected]&amp;amp;amp;amp;gt;;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
????????:&amp;amp;amp;amp;nbsp;2020??6??17??(??????) ????1:55
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
??????:&amp;amp;amp;amp;nbsp;"user-zh"<
&gt; [email protected]
&gt; &amp;gt; &amp;amp;amp;amp;gt;;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; ????:&amp;amp;amp;amp;nbsp;Re: 
??????FLINKSQL1.10????????????UV
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; ?? Flink 1.11 ????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; CREATE TABLE mysql (
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
&amp;amp;amp;amp;nbsp;&amp;amp;amp;amp;nbsp; time_str
&gt; STRING,
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
&amp;amp;amp;amp;nbsp;&amp;amp;amp;amp;nbsp; uv BIGINT,
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
&amp;amp;amp;amp;nbsp;&amp;amp;amp;amp;nbsp; PRIMARY
&gt; KEY (ts) NOT ENFORCED
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; ) WITH (
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
&amp;amp;amp;amp;nbsp;&amp;amp;amp;amp;nbsp;
&gt; 'connector' = 'jdbc',
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
&amp;amp;amp;amp;nbsp;&amp;amp;amp;amp;nbsp; 'url' =
&gt; &amp;gt; 'jdbc:mysql://localhost:3306/mydatabase',
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 
&amp;amp;amp;amp;nbsp;&amp;amp;amp;amp;nbsp;
&gt; 'table-name' = 'myuv'
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; );
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; INSERT INTO mysql
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; SELECT MAX(DATE_FORMAT(ts, 
'yyyy-MM-dd
&gt; HH:mm:00')),
&gt; &amp;gt; &amp;amp;gt; COUNT(DISTINCT&amp;amp;amp;amp;nbsp;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; user_id)
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; FROM user_behavior;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; On Wed, 17 Jun 2020 at 13:49, x <
&gt; [email protected]&amp;amp;amp;amp;gt;
&gt; &amp;gt; wrote:
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; 
??????????????????????"??????"????????????????????????????????????????????UV??
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; sink??????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; tm uv
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 2020/06/17 
13:46:00 10000
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 2020/06/17 
13:47:00 20000
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 2020/06/17 
13:48:00 30000
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; group by 
??????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt;
&gt; 
------------------&amp;amp;amp;amp;amp;nbsp;????????&amp;amp;amp;amp;amp;nbsp;------------------
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; ??????:&amp;amp;amp;amp;amp;nbsp;"Benchao Li"<
&gt; &amp;gt; [email protected]
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;amp;amp;gt;;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; ????????:&amp;amp;amp;amp;amp;nbsp;2020??6??17??(??????) ????11:46
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; ??????:&amp;amp;amp;amp;amp;nbsp;"user-zh"<
&gt; &amp;gt; [email protected]
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;amp;amp;gt;;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
????:&amp;amp;amp;amp;amp;nbsp;Re:
&gt; ??????FLINKSQL1.10????????????UV
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; Hi??
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
??????????????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 1. 
??????????group by + mini batch
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 2. window???? 
+ fast emit
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; ????#1??group
&gt; &amp;gt; 
by????????????????????????????????????????????????DATE_FORMAT(rowtm,
&gt; &amp;gt; &amp;amp;gt; 'yyyy-MM-dd')??
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
??????????????????????????????state
&gt; retention??????????????????????[1]
&gt; &amp;gt; ????????mini
&gt; &amp;gt; &amp;amp;gt; batch????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; ??????[2] 
????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; 
????#2????????????????????????tumble????????????????????????????????????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; fast
&gt; &amp;gt; &amp;amp;gt;
&gt; 
emit????????????????????experimental??feature????????????????????????????????????????????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; table.exec.emit.early-fire.enabled = true
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; table.exec.emit.early-fire.delay = 60 s
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; [1]
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt;
&gt; 
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/query_configuration.html
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; [2]
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt;
&gt; 
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; x 
<[email protected]
&gt; &amp;amp;amp;amp;amp;gt;
&gt; &amp;gt; ??2020??6??17?????? ????11:14??????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; 
??????????????????????0??????????????UV??????????????????????????????????????UV??????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt; CREATE
&gt; VIEW uv_per_10min AS
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt;
&gt; SELECT&amp;amp;amp;amp;amp;amp;nbsp;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt;
&gt; &amp;amp;amp;amp;amp;amp;nbsp;
&gt; &amp;gt; &amp;amp;gt; 
MAX(DATE_FORMAT(proctime&amp;amp;amp;amp;amp;amp;nbsp;,
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; 'yyyy-MM-dd
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt;
&gt; HH:mm:00'))&amp;amp;amp;amp;amp;amp;nbsp;OVER w
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt; AS
&gt; &amp;gt; time_str,&amp;amp;amp;amp;amp;amp;nbsp;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt;
&gt; &amp;amp;amp;amp;amp;amp;nbsp;
&gt; &amp;gt; COUNT(DISTINCT user_id) OVER
&gt; &amp;gt; &amp;amp;gt; w AS uv
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt; FROM
&gt; user_behavior
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt; WINDOW w
&gt; AS (ORDER BY proctime
&gt; &amp;gt; ROWS BETWEEN
&gt; &amp;gt; &amp;amp;gt; UNBOUNDED
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; PRECEDING AND
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt; CURRENT
&gt; ROW);
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt;
&gt; ??????????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt; PARTITION
&gt; BY
&gt; &amp;gt; DATE_FORMAT(rowtm, 'yyyy-MM-dd')
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; ??????????????????????????????????
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt;
&gt; PS??1.10??????????DDL??????????CREATE
&gt; &amp;gt; VIEW??
&gt; &amp;gt; &amp;amp;gt; &amp;amp;amp;gt; &amp;amp;amp;amp;gt; 
&amp;amp;amp;amp;amp;gt; ????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; --
&gt; &amp;gt;
&gt; &amp;gt; Best,
&gt; &amp;gt; Benchao Li
&gt;
&gt;
&gt;
&gt; --
&gt;
&gt; Best,
&gt; Benchao Li



-- 

Best,
Benchao Li

?????? ??????FLINKSQL1.10????????????UV

回复