From 0438dde0b6253a5d5c0de0215fee2fb43b1c34e6 Mon Sep 17 00:00:00 2001 From: heibaiying <31504331+heibaiying@users.noreply.github.com> Date: Tue, 5 Nov 2019 22:03:22 +0800 Subject: [PATCH] Update Flink_Windows.md --- notes/Flink_Windows.md | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/notes/Flink_Windows.md b/notes/Flink_Windows.md index 4d475e4..38e42e1 100644 --- a/notes/Flink_Windows.md +++ b/notes/Flink_Windows.md @@ -23,7 +23,7 @@ Time Windows 用于以时间为维度来进行数据聚合,具体分为以下 滚动窗口 (Tumbling Windows) 是指彼此之间没有重叠的窗口。例如:每隔1小时统计过去1小时内的商品点击量,那么 1 天就只能分为 24 个窗口,每个窗口彼此之间是不存在重叠的,具体如下: -
+
这里我们以词频统计为例,给出一个具体的用例,代码如下: @@ -55,7 +55,7 @@ env.execute("Flink Streaming"); 滑动窗口用于滚动进行聚合分析,例如:每隔 6 分钟统计一次过去一小时内所有商品的点击量,那么统计窗口彼此之间就是存在重叠的,即 1天可以分为 240 个窗口。图示如下: -
+
可以看到 window 1 - 4 这四个窗口彼此之间都存在着时间相等的重叠部分。想要实现滑动窗口,只需要在使用 timeWindow 方法时额外传递第二个参数作为滚动时间即可,具体如下: @@ -69,7 +69,7 @@ timeWindow(Time.minutes(1),Time.seconds(3)) 当用户在进行持续浏览时,可能每时每刻都会有点击数据,例如在活动区间内,用户可能频繁的将某类商品加入和移除购物车,而你只想知道用户本次浏览最终的购物车情况,此时就可以在用户持有的会话结束后再进行统计。想要实现这类统计,可以通过 Session Windows 来进行实现。 -
+
具体的实现代码如下: @@ -85,7 +85,7 @@ window(EventTimeSessionWindows.withGap(Time.seconds(10))) 最后一个窗口是全局窗口, 全局窗口会将所有 key 相同的元素分配到同一个窗口中,其通常配合触发器 (trigger) 进行使用。如果没有相应触发器,则计算将不会被执行。 -
+
这里继续以上面词频统计的案例为例,示例代码如下: @@ -125,4 +125,4 @@ public WindowedStream countWindow(long size, long slide) { ## 参考资料 -Flink Windows: https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/operators/windows.html \ No newline at end of file +Flink Windows: https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/operators/windows.html