Flink SQL Client中的session window图解

flink sql cookbook中的sql语句是:

SELECT  userid,SESSION_START(log_time, INTERVAL '10' SECOND) AS session_beg,SESSION_ROWTIME(log_time, INTERVAL '10' SECOND) AS session_end,COUNT(request_line) AS request_cnt
FROM server_logs
WHERE status_code = '403'
GROUP BY userid, SESSION(log_time, INTERVAL '10' SECOND);

session window

SQL语句详解

SQL语句的各个部分	解释
SELECT userid,	选择userid
SESSION_START(log_time, INTERVAL '10' SECOND) AS session_beg,	session window的起始时间
SESSION_ROWTIME(log_time, INTERVAL '10' SECOND) AS session_end,	session window的结束时间
COUNT(request_line) AS request_cnt FROM server_logs WHERE status_code = '403'	用户请求遭遇403的次数统计
GROUP BY userid, SESSION(log_time, INTERVAL '10' SECOND);	各个用户(userid)的各个session 分开统计(count)，统计结果互不干扰

注意SQL中的'10' second必须保持一致，否则SQL会无法运行

运行结果:

Flink SQL Client中的session window图解相关推荐

Flink SQL Client中的Chained (Event) Time Windows
Flink SQL Cookbook中有Chained (Event) Time Windows 该md文件举了两个例子, 前面一个例子是Chained Windows 后面一个例子是Non-Chai ...
Flink SQL Client注册SCALA UDF完整流程
UDF的完整maven工程與SQL https://github.com/appleyuchi/Flink_SQL_Client_UDF 完整操作步骤 ①mvn scala:compile packa ...
Flink SQL Client方言切换与datagen-＞Hive(DDL形式+streaming形式)
概述本文是对[1]的完整复现,补充了[1]中缺失的大量细节. 切换方言切换目标 Flink SQL Client命令切换为hive SET table.sql-dialect=hive; 切换为 ...
flink sql client讀取kafka數據的timestamp(DDL方式)
实验目的 Kafka的数据能让Flink SQL Client读取到本文是对[1]的详细记载具体操作步骤 ①啓動hadoop集羣,離開安全模式 ②各个节点都关闭防火墙: service firew ...
Flink SQL Client讀取csv中的數據(轉載+總結)
根據官方文檔[2] Flink SQL啓動方式啓動命令 (1)starting an embedded standalone process $FLINK_HOME/bin/sql-client.s ...
Flink SQL Client CLI 使用入门
参照:https://blog.csdn.net/boling_cavalry/article/details/105964425 一.SQL Client Flink 的 Table & S ...
Flink SQL Client注册JAVA UDF完整流程
概述听大佬说[1]里面有flink sql client注册udf的方法去看了一眼,全是文字,闹心,索性琢磨了一下,记录下来． UDF的完整maven工程 https://github.com/a ...
Flink SQL Client实现CDC实验
概述本文主要是對[7]中內容的復現环境组件版本 Flink(HA) 1.12 Zookeeper 3.6.0 flink-sql-connector-mysql-cdc 1.1.1 Mysql ...
Flink SQL Client读Kafka+流计算(DDL方式+代碼嵌入DDL/SQL方式)
#################################################################################################### ...

Flink SQL Client中的session window图解

Flink SQL Client中的session window图解相关推荐

最新文章

热门文章