蔚蓝流分析:翻滚的窗口
蔚蓝流分析:翻滚的窗口
提问于 2019-10-31 23:33:04
我有两个问题：
1)翻滚的窗户是如何工作的？
因此，假设我不断地发生事件，我会翻滚(小时,1)
然后，流分析将等待1小时，并分组，并给我一个记录
或者，一旦事件发生，它会给我记录，分组最后一个小时的数据？
( 2)在我的设想中，我要不断地付款，我需要当天的所有金额，每次交易时都要给我一笔钱。
因此，假设下面是我的事务数据
所以我们可以从图像中看到
- 当交易额达到30/10/2019 5:08:06时，流分析应该给出10美元的
- 当交易额达到30/10/2019 5:08:07时，流分析应该给出20美元
- 当交易额达到30/10/2019 5:08:08 :08时，流分析应该给出30美元
- 当交易额达到30/10/2019 6:08:09流分析应该给金额40美元
- 当交易额达到30/10/2019 7:08:11时，流分析应该给出50美元
- 当交易额达到30/10/2019 11:08:12时，流分析应该给出60美元
回答 1
Stack Overflow用户
发布于 2019-11-01 01:28:21
对于问题1，SA将等待1小时，然后分组，并给您一个记录作为输出。
每个窗口操作都输出窗口末尾的事件。的窗口在窗口开始时打开，在窗口结束时关闭。例如，如果您有一个从上午12:00到12:05的5分钟窗口，则此窗口将包括所有时间戳大于12:00的事件，并包含在12:05 AM之前的时间戳。窗口的输出将是基于聚合函数的单个事件，其时间戳等于窗口结束时间。
对于问题2，我相信您可以使用跳转窗口并定义最后1天(86400秒)的持续时间，如下所示：
SELECT Amount, SUM(Amount) as TotalTransactions
FROM <YourSAInput> TIMESTAMP BY TransactionDate
GROUP BY Amount, HoppingWindow(seconds, 86400, 1)跳转窗口规范由三个参数组成:时间单位、窗口大小(每个窗口持续多长时间)和hopsize (每个窗口相对于前一个窗口向前移动的次数)。
希望这能有所帮助。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/58652404
复制相关文章
相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号