会话在用户级别由5分钟的固定窗口定义，该窗口为不在先前会话中的每个新行启动(理想情况下，窗口持续时间取决于给定用户的先前行数，但目前我可以接受固定的窗口持续时间)。SELECT 1, TIMESTAMP('2020-01-01T01:00:00Z') -- new sessionSELECT * 我被卡住了，因为在我的推理中，
浏览 13提问于2020-02-27得票数 1
我想知道如何最好地在BigQuery standardSQL (而不是旧版)中做一个翻滚和滑动的窗口。Apache使这非常容易--对于长度为10分钟的‘滑动’窗口，每5分钟滑动一次，groupBy(“10分钟”，"5分钟“)和一个翻滚的窗口groupBy(”10分钟“)。(请注意总数上的结构)
浏览 3提问于2017-06-10得票数 1
回答已采纳
对于Google BigQuery基础设施，伙计们:我们已经运行了一组短时间运行的交互式查询，几个月来平均完成了大约5秒。从周五2/19开始，这些响应时间一直在稳步增长(SQL没有改变，我们正在处理使用滑动窗口查询的稳定数据流)
浏览 2提问于2016-02-22得票数 3
回答已采纳
wj函数的参数窗口是否只支持持续时间类型？如果我想按行进行选择，我应该如何处理它？
M数据均以交易日为基础。如果是周末或假日，持续时间类型窗口中的数据将为空。我现在将moving用于向后滑动窗口。任何用于前向滑动窗口的函数，如moving(fun, X, -n)
浏览 11提问于2022-01-25得票数 0
我需要2个窗口(不是10滑动窗口与20滑动窗口)或固定持续时间的2个窗口，提前点火。我需要2个窗口，这应该保持向前滚动一分钟(持续时间10分钟和20分钟)每分钟。或者，如果我可以丢弃除了最新的滑动窗口之外的所有窗口，我的问题就可以解决了。否则，多个滑动窗口是非常昂贵的
浏览 14提问于2019-02-21得票数 0
1回答
卡夫卡滑动窗
、、、
我希望实现Kafka流滑动窗口，并为特定的窗口持续时间执行聚合，并且每个窗口只输出一个结果。
现在，我已经搜索了整个堆栈溢出，但是我无法找到与滑动窗口相关的代码实现。
浏览 0提问于2019-07-18得票数 0
在spark streaming中，我们接收的DStreams是一批RDDs。那么窗口如何进一步提供帮助呢？
据我所知，它还批处理RDDs。如果我错了，请纠正我( Spark Streaming的新手)。
浏览 4提问于2015-10-08得票数 7
回答已采纳
我正在使用一个BigQuery表数据源。它是“无界的”，因为它是通过批处理过程更新的。它包含来自服务器日志的按会话键的报告数据，其中每一行捕获一个请求。我想使用beam api开发一个基于自定义Java的模板，其目标是：
根据会话度量导出可过滤窗口级别的度量，例如，在前一个窗口中有错误的会话百分比和每个筛选属性的错误百分比我目前的想
浏览 3提问于2020-01-02得票数 0
回答已采纳
我的用例是，我需要显示过去3个月、6个月和1年内任何时间点的客户使用情况统计数据。我计划在上面提到的持续时间内使用KStream滑动窗口。我看到的大多数示例都使用以分钟或秒为单位的持续时间。我想知道滑动窗口是否可以使用较大的持续时间？对性能有影响吗？它应该使用任何特定的配置来获得最佳性能吗？
谢谢你，Jinu
浏览 11提问于2021-03-09得票数 1
1回答
我实现了一个具有多个无界源和侧输入的数据管道，用滑动窗口连接数据(30s和10s)，并将转换后的输出发送到Kafka主题中。我的问题是，在窗口的前10秒内收到的数据被发出了3次(即)。每当新窗口开始时，直到第一个窗口完成为止，都会触发。如何只发出一次转换后的数据或避免重复？
我使用过废弃的烧制窗格，这并没有什么区别。每当我尝试将窗口关闭行为设置为FIRE_ALWA
浏览 0提问于2019-07-17得票数 0
我们正在运行数百个固定的SQL查询，这些查询在滑动的时间窗口上查询数据(例如，SQL的结构保持不变)。昨天大约21:09 - 21:13，出现了几百个BigQuery引发错误的案例：{u‘’reason‘：u’‘invalidQuery’，u‘’message‘：u’评估子公司查询时出错‘，u’‘location’：u'query'}
今天，对于更多的查询，这种情况在16:05到16:14之间再次
浏览 0提问于2016-08-06得票数 0
回答已采纳
1回答
Azure流分析窗口
、、、
我遇到了流分析窗口的问题。输入到“我的流分析作业”是一个事件流，包含来自属于信号的传感器/实体的温度读数。每个信号大约有600个实体。一个示例事件应该是这样的。，则将一个“警报”插入到Azure SQL数据库中。e.EntityId = entities.ArrayValue.Id e.Temperature > entities.ArrayValue.Threshold
我现在需要的是在上面加一个滑动
浏览 1提问于2016-12-16得票数 0
我使用可变队列ssc.queueStream(red)将数据放入流中当我在做一个for (time <- 0L to stream.slideDuration.milliseconds + 10) {
println("time "+ time
浏览 0提问于2015-10-19得票数 0
2回答
有什么好的经验法则可以帮我确定我是否应该
经典的批处理编程，每小时的团队评分，所有时间的用户评分，用户行为分析都觉得它们很容易通过SQL创建(给定的"created"和"write&qu
浏览 1提问于2016-02-04得票数 0
1回答
给定下面的类和数据结构，我想要计算每个连续3小时滑动窗口的计数总和，类似于以下结果： public class Log { private LocalDateTime110 2018-10-10T17:30:00 4
11 2018-10-10T17:35:00 7 日志的时间戳是升序的，从第一条记录算起每3小时窗口(可以跨越不同的一天
浏览 76提问于2019-03-09得票数 2
1回答
如何控制Flink检查点的大小
、、、、
我正在运行一个简单的Flink聚合作业，它从Kafka消耗，并应用多个窗口(1小时、2小时hr...upto )和特定的滑动间隔，并在窗口上进行聚合。有时工作会重新启动，当它从最新的Kafka数据中启动窗口时，我们就会丢失数据。为了克服这一问题，我们启用了检查点，并且我看到检查点的大小正在增加( HashMapStateBackend具有Hdfs存储)。对于一个永久运行的Flink作业来说，什么是最好的检查方法?我们
浏览 10提问于2022-11-03得票数 0
如何计算链接到BigQuery的Firebase分析原始数据中的会话持续时间？我使用下面的博客对每个记录中嵌套的事件使用flatten命令计算用户，但我想知道如何按国家和时间计算会话和会话持续时间。(我配置了许多应用程序，但是如果您可以帮助我使用SQL查询来计算会话持续时间和会话，这将有很大的帮助)
浏览 5提问于2017-03-02得票数 16
1回答
我在Azure中创建了一个流分析的工作，我想在Power中显示结果。这项工作非常简单，因为我想要做的就是每1秒显示一次在最后10分钟内发生的事件数。我有以下选择：
使用一个持续时间为10分钟的滚动窗口:不，因为这不会每1秒显示一次结果，而是在10分钟之后显示结果。使用跳跃窗口:HoppingWindow(持续时间(分钟，10)，Hop(第二，1))。这在前10分钟有效，但在那之后没有，因为它跳-滑了1秒。使用大小为10分钟的<em
浏览 2提问于2019-09-05得票数 1
我有4个不更改名称的段，它们是(segment1.ts，segment2.ts，segment3.ts，segment4.ts)，但它们每5秒更新一次(但保持相同的名称)。我认为m3u8配置是正确的，只有媒体序列是错误的，我不知道应该如何配置它，有什么帮助吗？？
浏览 0提问于2020-10-02得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
