??blinkval setttings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()
----
??:"Benchao Li"https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/query_configuration.html#idle-state-retention-time
sorry,group agg.
tableConfig.setIdleStateRetentionTime(Time.minutes(2),Time.minutes(7))??.
----
??:"Benchao
??1.10.1??sinkwindow??count
distinct??window??count
distinct??windowgroupDATE_FORMAT(rowtm,
'-MM-dd') sql??
val rt_totaluv_view : Table =
checkpoint??
tableConfig.setIdleStateRetentionTime(Time.minutes(2),Time.minutes(7)),??key
----
??:"Jark
??1.10??,???
val resTmpTab: Table = tabEnv.sqlQuery(
"""
SELECT MAX(DATE_FORMAT(ts, '-MM-dd HH:mm:00')) time_str,COUNT(DISTINCT
userkey) uv
FROM user_behaviorGROUP BY DATE_FORMAT(ts, '-MM-dd')""")
val
----
??:"Jark Wu"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
??"??"UV??
sink??
tm uv
2020/06/17 13:46:00 1
2020/06/17 13:47:00 2
2020/06/17 13:48:00 3
group by ??
----
??:"Benchao
??0??UV??UV??
CREATE VIEW uv_per_10min AS
SELECT
MAX(DATE_FORMAT(proctime, '-MM-dd HH:mm:00'))OVER w AS
time_str,
COUNT(DISTINCT user_id) OVER w AS uv
FROM user_behavior
WINDOW w AS (ORDER BY proctime
