计算Elasticsearch中滑动时间窗口的更改百分比
滑动时间窗口是Elasticsearch中一种常用的时间范围查询方式，它允许我们在一段时间内对数据进行聚合和分析。更改滑动时间窗口的百分比是指调整滑动时间窗口的大小，以适应不同的数据分析需求。
滑动时间窗口的概念：滑动时间窗口是一种基于时间的查询方式，它将时间范围划分为固定大小的窗口，并在每个窗口内进行数据聚合和分析。例如，我们可以将时间范围划分为每小时一个窗口，然后计算每个窗口内的数据总和、平均值等。
滑动时间窗口的分类：滑动时间窗口可以根据窗口的大小和滑动的步长进行分类。窗口的大小决定了每个窗口内的时间范围，而滑动的步长则决定了窗口之间的时间间隔。常见的窗口大小包括小时、天、周、月等，而步长可以是固定的时间间隔，也可以是根据数据的时间间隔自动调整。
滑动时间窗口的优势：滑动时间窗口可以帮助我们对时间序列数据进行实时分析和监控。通过调整窗口的大小和步长，我们可以灵活地控制数据的粒度和聚合方式，从而满足不同的分析需求。此外，滑动时间窗口还可以提高查询效率，减少数据的处理量。
滑动时间窗口的应用场景：滑动时间窗口广泛应用于日志分析、监控系统、实时数据分析等领域。例如，在日志分析中，我们可以使用滑动时间窗口来计算每个时间窗口内的日志数量、错误率等指标，以便及时发现和解决问题。在监控系统中，滑动时间窗口可以用于计算每个时间窗口内的平均响应时间、请求量等指标，以便及时监控系统的性能。
推荐的腾讯云相关产品：腾讯云提供了一系列与Elasticsearch相关的产品和服务，可以帮助用户快速搭建和管理Elasticsearch集群。其中，推荐的产品包括：
- 云搜索：腾讯云搜索是一种基于Elasticsearch的全文搜索服务，提供了简单易用的API接口和丰富的搜索功能，可以帮助用户快速构建全文搜索应用。
- 云原生数据库TDSQL-C：TDSQL-C是腾讯云推出的一种云原生数据库，支持Elasticsearch作为存储引擎，可以提供高性能的全文搜索和分析功能。
- 弹性MapReduce：弹性MapReduce是腾讯云提供的一种大数据处理服务，可以与Elasticsearch集成，实现对大规模数据的分布式计算和分析。
- 弹性容器实例：弹性容器实例是腾讯云提供的一种无需管理服务器的容器服务，可以快速部署和运行Elasticsearch集群，简化了集群的管理和维护。
更多关于腾讯云相关产品的介绍和详细信息，可以访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
wj函数的参数窗口是否只支持持续时间类型？如果我想按行进行选择，我应该如何处理它？
M数据均以交易日为基础。如果是周末或假日，持续时间类型窗口中的数据将为空。我现在将moving用于向后滑动窗口。任何用于前向滑动窗口的函数，如moving(fun, X, -n)
浏览 11提问于2022-01-25得票数 0
最近我遇到了一个问题。算法的部分要求计算长度为K的滑动窗口的最大单元和。其中K的范围从1<=K<=N (数组的N长度)。
示例，如果我有一个数组A作为5,3,12,4
长度为1：5 + 3 + 12 + 4 = 24的滑动窗口
长度为2：5 + 12 + 12 = 29的滑动窗口
长度为3：12 + 12 = 24的滑动窗口
长度为4：12的滑动窗口
Final answer is 24,29,24,12。
我试过这个O(N^2)。对于长度为K的每一个滑动窗口，我可以计算O(N)中的最大值。因此，由于K是向上N的，所以总的复杂性是O(N^2)。
我正在寻找O(N)或O(NlogN)
浏览 8提问于2016-02-08得票数 6
回答已采纳
1回答
我使用的滑动窗口风暴实现：
这是我的拓扑结构：
public static void main(String[] args) throws Exception {
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("rabbitSpout", new RabbitMQSpout());
builder.setBolt("filterBolt", new FilteringBolt()).shuffleGrouping("rabbitSpout&
浏览 0提问于2017-04-01得票数 0
回答已采纳
1回答
我试着在Flink创建我的第一份实时分析工作。这种方法类似于kappa体系结构，所以我有关于Kafka的原始数据，在那里，我们收到了任何实体状态的每一次变化的信息。
因此，这些消息的形式如下：
(id,newStatus, timestamp)
我们希望为每个时间窗口计算处于给定状态的项的计数。因此，输出应该是如下形式的：
(outputTimestamp, state1:count1,state2:count2 ...)
或者同等的。这些行应该在任何给定的时间包含处于给定状态的项的计数，其中与id相关联的状态是为该Id观察到的最新消息。在任何情况下都应该计算id的状态，即使事件比正在处理的事
浏览 3提问于2016-09-30得票数 2
回答已采纳
2回答
我正在创建一个系统维护页面，该页面显示何时执行系统维护。页面上有一个进度条，显示已经完成了多少维护。我试图通过计算系统维护窗口的百分比/时间来实现进度条的自动化，但是我遇到了问题。
数据库中存储了三个不同的时间:开始时间、结束时间和当前时间。我需要能够计算出维护工作的剩余时间，并将其显示在进度栏中，从1%到100%。脚本应该能够计算从开始时间到结束时间之间的时间。
我最初尝试计算两次之间的百分比(当前时间和结束时间)，但这是行不通的，因为方程中需要三个因素--开始时间、结束时间和当前时间。
如能对此提供任何帮助，将不胜感激。
浏览 8提问于2011-03-19得票数 4
回答已采纳
我有三个流A，B和C，我应该加入到一个单一的流，让我们称之为ABC，并做一些操作。
重要的是我使用大小为X和幻灯片Y的滑动窗口，其中Y为<= X*3。
所有流都包含一些用于连接的公共ID，而X、Y是以秒为单位定义的时间参数。
我目前的实现是使用大小为X的滚动窗口将流A和B连接到AB中，然后使用大小为X的滑动窗口和幻灯片Y将AB与C连接起来。
在这样的情况下，这可能会导致错误的答案，例如:流A在时间0接收消息，B流在time Y+1接收消息。在这种情况下，由于Y+1 < X，两条消息都应该进入同一个滑动窗口，但最终结果是当我加入AB和C时，B的消息由于初始滚动窗口而丢失。
我是否可以
浏览 2提问于2019-12-31得票数 0
回答已采纳
2回答
我正在使用Elasticsearch 1.7.3为分析报告积累数据。
我有一个包含文档的索引，其中每个文档都有一个名为“工期”的数字字段(请求花了多少毫秒)，还有一个名为“component”的字符串字段。可以有许多具有相同组件名称的文档。
例如：
{"component": "A", "duration": 10}
{"component": "B", "duration": 27}
{"component": "A", "duration": 5}
浏览 1提问于2015-11-04得票数 4
回答已采纳
通过一些数值例子，我试图了解如何计算滑动窗口数据传输的吞吐量。下面是我分析的例子。
示例
主机A通过全双工链路向主机B发送数据。A和B采用滑动窗口协议，发送和接收窗口大小各为5。仅从A到B发送的数据包大小为1000个字节，其中一个数据包的传输时间为50 us。传输延迟为200 us。假设Ack数据包需要可忽略的传输时间。以Mbps计的最大可实现吞吐量是多少？
A. 7.69 B.11.11 C. 12.33 D. 15.00
分析
往返时间是2* 200 us = 400 us。.=‘2’>.一个
填充发送窗口所需的时间=窗口大小(5) *1包(50 us)的传输时间=
浏览 4提问于2014-02-21得票数 3
回答已采纳
我想知道如何最好地在BigQuery standardSQL (而不是旧版)中做一个翻滚和滑动的窗口。
Apache使这非常容易--对于长度为10分钟的‘滑动’窗口，每5分钟滑动一次，groupBy(“10分钟”，"5分钟“)和一个翻滚的窗口groupBy(”10分钟“)。
考虑到我有一个简化的订单行，其中包括：
orderId,
orderPlacedTimestamp,
orderTotals.grandTotalNet,
orderTotals.grandTotalGross
(请注意总数上的结构)
我需要两个总订单销售价值如下：
每时每刻的销售窗口
滑动10分钟
浏览 3提问于2017-06-10得票数 1
回答已采纳
1回答
计算一半的百分比
、、、
我的数学糟透了，所以这个问题我需要一些帮助，因为到目前为止，我花了两个小时，而我却无处可寻。
我有一个可触摸的滑动面板(就像你在桌面单元格上得到的“滑动显示”功能)。这是一个丑陋的ascii图
-----------------------------
| Slide | Reveal |
-----------------------------
向左滑动“幻灯片”位，以显示显示位。我现在要做的是计算出，当触摸结束时，显示了多少显示，或者按下打开还是关闭。
我知道显示框的宽度是110，我也可以计算出如果幻灯片左移到-75，那么“打开百分比”是75%。
Open Perc
浏览 2提问于2017-05-25得票数 0
回答已采纳
1回答
我有个问题。知道如何在特定的时间内将特定的数字增加到更大的数字吗？(使用jQuery)例如，我想要使百分比条和当条形滑动到特定的尺寸时，同时将数字从0增加到100。我创造酒吧，但不知道如何在特定的时间内实现数字转换。从视觉上看，它看起来如下：
浏览 1提问于2014-04-13得票数 0
回答已采纳
我在时间序列数据上使用了一个分类模型，在将数据分解为训练和测试之前，我对数据进行规范化。现在，我知道训练数据和测试数据应该分开处理，以防止数据泄漏。在这里，规范化步骤的正确顺序是什么？我是否应该分别应用步骤1、2、3来训练和测试使用滑动窗口分割数据后的数据？我在这里使用一个滑动窗口来比较每一个小时(测试)和它之前的24小时数据(火车)。这是我目前在管道中使用的命令。
使用滑动窗口(长度为24小时(列车)和每1小时(测试)一次)将每个hourStandardizationSplit数据放入列车并进行测试，适合使用列车数据预测使用测试数据的模型。
浏览 0提问于2020-07-04得票数 1
回答已采纳
我试图计算百分比的变化(周期大于1)，在一个系列的末尾有一个缩小的窗口效应。
下面的示例没有产生所需的结果：
import pandas as pd
import numpy as np
labels = ['A', 'A', 'A', 'A', 'A', 'B', 'A', 'C', 'B', 'B', 'B', 'B', 'C', 'C', &
浏览 0提问于2019-06-29得票数 0
回答已采纳
链接：
与翻滚或跳跃窗口不同的是，滑动窗口只在窗口内容实际更改时才计算聚集点。当事件进入或退出窗口时，将计算聚合。因此，每个窗口至少有一个事件。类似于跳转窗口，事件可以属于多个滑动窗口。
假设窗口的持续时间是10，那么我的理解是，该窗口覆盖了之前的10秒(包括当前事件)。因此，在下图中，窗口号(假设编号从上到下开始) 1、2、3是正确的，因为它落后于(包括)事件发生的10秒。数字6也是正确的。
窗口编号4、5和7的理由是什么？
浏览 8提问于2022-11-04得票数 0
我在时间序列数据上使用了一个分类模型，在将数据分解为训练和测试之前，我对数据进行规范化。现在，我知道训练数据和测试数据应该分开处理，以防止数据泄漏。在这里，规范化步骤的正确顺序是什么？我是否应该分别应用步骤1、2、3来训练和测试使用滑动窗口分割数据后的数据？我在这里使用一个滑动窗口来比较每一个小时(测试)和它之前的24小时数据(火车)。这是我目前在管道中使用的命令。
移动平均(平均数)
每小时重采样一次
标准化
使用滑动窗口(长度为24小时(火车))将数据分割成列车和测试，每1小时(测试)滑动一次)
利用列车数据拟合模型
使用测试数据进行预测
浏览 0提问于2020-07-04得票数 3
回答已采纳
假设我有一个带有键和时间戳的流。我想在每个窗口(滑动窗口)中创建这些关键点的笛卡尔乘积。如果我有键1,2,3,4，并且我将并行度设置为2，我想用以下方式对它们进行“分组”：
1 - 2 2 - 3
1 - 3 2 - 4
1 - 4 3 - 4
并且我希望在每个窗口中按组处理元素。因此，假设上面的元素(1,2,3,4)基于它们的时间戳在同一个窗口中。
在最简单的形式中，我的问题是:给定每个滑动窗口中的一些元素(可能包含几个键)，我希望创建上述示例中这些键的组合，并对这些分组的元素应用自定义算法。
到目前为止，我尝试的是使用
.assignAscendingTimestamps
浏览 7提问于2017-02-10得票数 0
1回答
我正在尝试做一个elasticsearch查询，在其中，我需要在elasticsearch表中搜索一个时间框架。我有记录有开始时间和结束时间。在UI中，我给出了一个开始时间和结束时间，这是我需要搜索文件的时间窗口。假设记录中的开始时间和结束时间的时间窗口小于用户输入的时间窗口，我创建了以下查询：
{
"_source":["filename","starttime","endtime"],
"sort":[{
"starttime":{"order&#
浏览 1提问于2018-11-08得票数 0
回答已采纳
1回答
我在Azure中创建了一个流分析的工作，我想在Power中显示结果。这项工作非常简单，因为我想要做的就是每1秒显示一次在最后10分钟内发生的事件数。但是，当最后10分钟过去时，我需要重新设置计数器，这意味着我希望窗口在10分钟后重新启动。
我有以下选择：
使用一个持续时间为10分钟的滚动窗口:不，因为这不会每1秒显示一次结果，而是在10分钟之后显示结果。
使用跳跃窗口:HoppingWindow(持续时间(分钟，10)，Hop(第二，1))。这在前10分钟有效，但在那之后没有，因为它跳-滑了1秒。
使用大小为10分钟的滑动窗口:否，因为当事件发生时，它会滑动10分钟。
使用Se
浏览 2提问于2019-09-05得票数 1
有没有什么算法可以将elasticsearch中搜索的max_score转换成百分比分数?请建议一些想法。
浏览 0提问于2020-07-15得票数 0
4回答
我有一个简单的窗口窗体，就像这样: 1)当点击一个按钮时，将执行一个需要很长时间才能完成的操作，2)一个标签，显示正在进行的进度的百分比。
在我提到的长操作中，我编写了更新标签的Text属性的代码，但它不起作用！
请帮助我正确显示进度状态。
浏览 0提问于2010-03-28得票数 1
回答已采纳
1回答
我试图修改滑块：，以更新进度条百分比，如总数字值，以便在滑动过程中在步骤之间跳跃。如何计算滑块中的整数百分比？
负责这方面的职能：
function mousemove(event) {
scope.percent = Math.max(0, Math.min((event.clientX - scope.l) / scope.w * 100, 100));
if(scope.updateOnDrag)
{
scope.update();
}
scope.redraw();
}
浏览 3提问于2015-03-11得票数 0
回答已采纳
背景
我们需要知道什么时候比通常更高的请求接收到状态代码500的响应。不是原始计数，而是总数的百分比。
Web请求日志被发送到Elasticsearch，并与Grafana一起可视化。
使用插件，我们创建了一个仪表板，它显示状态代码为500的所有请求的百分比。
查询A-统计状态代码为500的所有位置
查询B-计数所有
查询数学: A/B * 100
我们甚至将小部件中的阈值设置为当其达到1%时变为红色。
那很容易。当然，这需要有人来看仪表盘。我们需要的是警报。
问题
如何创建在相同情况下触发的警报--即500 s的数量超过请求总数的1%的给定时间。
我知道Alerts只适用于图
浏览 3提问于2020-03-10得票数 0
2回答
我在Matlab中用一个简单的窗口函数编写了一个代码，以便应用简单的重叠，并将算法添加到我的输入信号中。
到目前为止，这就是我所写的：
[s_a,Fs] = audioread('a.wav');
frame_dur = 0.04; %length of my window in time
frame_stride = 0.01; %shift of every single window in time
frame_len = round(frame_dur * Fs);
frame_step = round(frame_stride*Fs);
win = hammin
浏览 0提问于2018-12-15得票数 1
回答已采纳
1回答
我试图复制在这个数据集上完成的信号预处理：
传感器信号(加速度计和陀螺仪)采用噪声滤波预处理，然后在固定宽度的2.56秒滑动窗和50%重叠(128读数/窗)中采样。
我试图在Matlab上执行我的所有功能，并在我的加速度信号上创建一个固定宽度的滑动窗口。
我的主要领域是人工智能分类，没有信号预处理方面的背景知识。我已经尝试研究等很长时间了，但我不明白我需要对我的信号做什么。
我有51.2采样频率产生的信号。请帮助我如何生成一个像在链接数据集上所做的抽样窗口？
浏览 4提问于2017-07-03得票数 0
如何使用基于固定大小计数的窗口实现滑动窗口聚合(或转换)？
如果我有如下所示的流数据
input stream = 1,2,3,4,5,6,7,8...
假设时间与这里无关。假设我的聚合函数是平均值，窗口大小固定在3个记录(不是3Millis，3秒，3个小时等)，我希望我的输出流是
output stream = avg(1,2,3), avg(2,3,4), avg(3,4,5), avg(4,5,6), avg(5,6,7)... = 2,3,4,5,6...
卡夫卡流作品中记录的Windows是“基于时间的”。甚至基类窗口的构造函数都有以下签名：
Window(long startMs,
浏览 2提问于2018-03-03得票数 4
1回答
我想测量频率响应函数。为了测量频响函数，我们应该将响应信号乘以一个窗口，如高斯窗口或Hann窗口。但在下面的专利中，他们声称我们使用相对较短的时间滑动窗口。在这几个月里，我已经多次研究了下面的美国专利：
我真的我不能理解我如何定义相对短时间的滑动窗口。总结：
问候
浏览 2提问于2017-01-19得票数 1
1回答
源：动态数据流
Sink：弹性搜索
都可以使用AWS服务。
另外，在AWS动态数据分析应用程序上运行我的Flink工作
我面临一个问题，窗口功能的flink。我的工作看起来像这样
DataStream<TrackingData> input = ...; // input from kinesis stream
input.keyBy(e -> e.getArea())
.window(TumblingProcessingTimeWindows.of(Time.seconds(10)))
.reduce(new
浏览 7提问于2021-12-13得票数 0
回答已采纳
1回答
我正在处理一个高分辨率的数据集，用于提取所需的图像对象。为此，我应用了HOG + SVM。虽然我得到的结果是非常有希望的，并且在操作上被接受，但这个任务的速度是令人讨厌的！对于每个大小为2800 * 1400的图像，算法需要4分钟才能完成，这与我需要的时间相去甚远。大部分时间都花在执行滑动窗口上。我需要这个识别程序在10秒内完成。由于我使用了Matlab，所以似乎不可能达到10秒，所以我不得不考虑C++。然而，我从来没有使用过C++，也没有足够的时间来学习它来完成这个任务。
我想知道有什么方法可以在Matlab或Python中加快滑动窗口的速度，以便在1分钟内完成识别？
浏览 7提问于2016-03-08得票数 1
我知道有两种方法可以做反向测试，滑动窗口和扩展窗口。 在实践中，哪种方法更好？每种方法的优缺点是什么？ 在我看来，如果时间序列模式与当前事件更相关，那么滑动方法更好。 滑动窗口如下图所示 ? 展开窗口，如下图 ? 来源：https://www.kaggle.com/cworsnup/backtesting-cross-validation-for-timeseries/notebook
浏览 89提问于2020-01-22得票数 0
我是新的火花流。我知道窗口大小需要批处理间隔的倍数。但是滑动间隔是如何工作的呢？如果我有3作为窗口大小和2作为滑动间隔，难道没有重叠，当我计算说字计数？还是滑动间隔和批处理间隔应该相同？
浏览 1提问于2018-06-04得票数 11
回答已采纳
1回答
我想计算一下我的流中两个值之间的变化率：
1mn SlidingWindow中的AVG(值)
前一分钟的SlidingWindow值为1mn
我在文档中唯一找不到的是如何创建一个“延迟”滑动窗口，这意味着它在实际时间之前开始2mn，并在实际时间之前结束1mn，这样我就可以进行一些计算，比如变化率。
浏览 0提问于2018-04-27得票数 0
回答已采纳
1回答
如何每n秒钟清空缓存(这样我们就可以对第二个窗口批处理窗口查询的数据运行查询)？我只能在点火代码中找到FIFO和基于LRU的驱逐策略，其中驱逐策略基于被添加或修改的缓存条目。
我知道我们可以使用CreatedExpiryPolicy有一个滑动窗口
cfg.setExpiryPolicyFactory(FactoryBuilder.factoryOf(new CreatedExpiryPolicy(new Duration(SECONDS, 5))));
但我不认为这能帮我维护批处理窗口。FIFO或LruEvictionPolicy也不会。
我需要一些驱逐政策，这是基于一些静态时间窗口(例如，每
浏览 2提问于2017-08-02得票数 1
我有一个网页，通过滑动从顶部带来另一个页面…我已经使用jquery animate实现了这一点。现在我的问题是，我如何知道animate()方法的进度百分比……就像从页面开始滑动到完成
谢谢
浏览 0提问于2012-02-17得票数 4
回答已采纳
3回答
我正试着更快地理解这一切-RCNN，
来自https://www.quora.com/How-does-the-region-proposal-network-RPN-in-Faster-R-CNN-work
然后在这些特征映射上在空间上运行滑动窗口。滑动窗口的尺寸为n×n (这里为3×3)。对于每个滑动窗口，产生一组9个锚，它们都具有相同的中心(xa，ya)(xa，ya)，但具有3个不同的纵横比和3个不同的尺度，如下所示。请注意，所有这些坐标都是针对原始图像计算的。
📷
对于我的观点，它比其他文章要清楚得多，但仍然很难理解功能地图是如何生成的。
我看到了另一张流动照片：
📷
📷
📷
问题是，
浏览 0提问于2018-01-31得票数 8
我试图确定SlidingDrawer在安卓系统中的“开放”百分比。看来抽屉里只有onOpen、onClose和onScroll侦听器。OnScroll仅提供用于确定滚动何时结束和何时开始的方法。
TouchEvents也不能工作，因为SlidingDrawer可以在不被触摸的情况下滑动。
我尝试使用SlidingDrawer ()获取getAnimation的动画(然后根据它确定百分比)，但返回null，getLayoutAnimation()也返回null。
有什么想法吗？
浏览 2提问于2011-06-14得票数 6
我正在使用星火结构流foreachBatch()手动维护一个滑动窗口，其中包括最后200000条条目。每一次小批处理，我都会收到大约50行。在这个滑动窗口，我是手动计算我想要的节拍器，如最小，最大，等等。
火花还提供了滑动窗口功能。但我有两个问题：
滑动窗口更新时的间隔只能基于一个时间段进行配置，但似乎不可能强制每个微批进入更新。有没有可能我看不见？
更大的问题:似乎我只能使用分组(如：)进行聚合
val windowedCounts = words.groupBy(
window($"timestamp", "10 minutes", &#
浏览 5提问于2022-05-06得票数 0
假设我想要计算过去10分钟内每分钟后特定指标的平均值，并将其与过去20分钟内每分钟后相同指标的平均值进行比较。我需要2个窗口(不是10滑动窗口与20滑动窗口)或固定持续时间的2个窗口，提前点火。我需要2个窗口，这应该保持向前滚动一分钟(持续时间10分钟和20分钟)每分钟。或者，如果我可以丢弃除了最新的滑动窗口之外的所有窗口，我的问题就可以解决了。否则，多个滑动窗口是非常昂贵的。 你能帮个忙吗？一个自定义的WindowFn()函数将非常有用
浏览 14提问于2019-02-21得票数 0
1回答
我有张桌子看起来像这样：
Day | Count
----+------
1 | 59547
2 | 40448
3 | 36707
4 | 34492
我希望它能够查询这样的结果集：
Day | Count | Percentage of 1st row
----+-------+----------------------
1 | 59547 | 1
2 | 40448 | .6793
3 | 36707 | .6164
4 | 34492 | .5792
我尝试过使用窗口函数，但似乎只能得到总数的一个百分比，如下所示
浏览 4提问于2014-01-14得票数 0
回答已采纳
例如，我有索引pizzas。我还有布尔过滤器
"bool": {
"should": {
"toppings": [
{
"query": "Tomatoes"
},
{
"query": "Mushrooms"
}
]
}
}
ElasticSearc
浏览 0提问于2015-08-28得票数 1
回答已采纳
1回答
让最大宽度的柱子变液体？
、、、
我有一个流畅的/响应性的列布局，如：
.row{
float:left;
max-width:960px;
width:100%;
}
.column{
float:left;
margin:0 15px;
}
.column:first-child{
margin-left:0;
}
.column:last-child{
margin-right:0;
}
.column.third{
max-width:300px;
}
html：
<div clas="row">
<div
浏览 2提问于2014-04-28得票数 1
回答已采纳
2回答
我有两个问题：
在计算RTT时，是否应考虑传输时间？
两站之间的距离M和N是L公里。所有帧都是K位长的。每公里的传播延迟为t秒。设T位/秒为信道容量。假设处理延迟可以忽略不计，当使用滑动窗口协议时，帧中序列号字段的最小位数是多少？
浏览 6提问于2013-02-02得票数 1
1回答
卡夫卡滑动窗
、、、
我希望实现Kafka流滑动窗口，并为特定的窗口持续时间执行聚合，并且每个窗口只输出一个结果。
现在，我已经搜索了整个堆栈溢出，但是我无法找到与滑动窗口相关的代码实现。
浏览 0提问于2019-07-18得票数 0
1回答
跳跃与滑动窗
、、
据我所知，滚动窗口是设置为一个间隔，事件的不重叠和到期在设定的时间间隔。现在，跳窗和滑动窗都重叠，在跳窗的情况下，我们有跳间隔和正常窗口间隔，而滑动窗口具有除窗口间隔以外的滑动间隔。我在上查看了这个链接，我理解它，但滑动间隔似乎也是一样的。有谁能帮我解释一下区别吗。
浏览 3提问于2017-04-03得票数 5
1回答
我使用Apache Storm的滑动窗口技术来获取24小时窗口长度和1小时滑动间隔长度的数据。当第一个TupleWindow到达时，TupleWindow中的每个元组都会启动一个聚合过程。
我的聚合过程会一直等到下一个TupleWindow到达。一旦TupleWindow到达，聚合过程就会启动，并消耗大量资源。我想知道Apache Storm是否有能力实时发送数据(而不是等到窗口的最后一项到达)。在这种情况下，我可以实时聚合所有内容
有相应的配置吗？
谢谢
浏览 21提问于2018-02-13得票数 1
1回答
我想在ScrollView上举办一个类似onSwipe的活动，而在Swiper上举办onSwipe这样的活动。在这个回调中，我想得到“滑动进度”(例如，对第二个项目滑动了50% )。对于所有支持的回调，我可以在滑动开始或结束时做一些事情，但我也希望所有的步骤在两者之间。我怎么能这么做？
浏览 4提问于2020-05-24得票数 0
回答已采纳
2回答
假设我们得到一个大小为NxN的整数像素矩阵和一个整数k窗口大小。我们需要使用滑动窗口找到矩阵中的所有局部最大值(或最小值)。这意味着如果一个像素与它周围窗口中的所有像素相比有一个最小(最大)值，那么它应该被标记为最小(最大)。有一种众所周知的滑动窗口最小值算法，它在向量中找到局部最小值，但在矩阵中找不到
你知道可以解决这个问题的算法吗？
浏览 1提问于2012-05-24得票数 7
我希望我的安卓游戏使用LibGDX继续跟踪游戏中的事件，即使它不是活动窗口。
例如，如果游戏不是活动的话，我有一个随时间减少的属性。当stat达到一定百分比时，我想将通知推到android平台上。
我发现了一些信息推送android通知。然而，当一个不同的应用程序或活动出现在主屏幕上时，我找不到一个关于如何使一个属性在游戏中持久存在的方法。
浏览 0提问于2017-01-30得票数 1
回答已采纳
1回答
假设我有一个带有时间戳字段列的输入df，并且当设置窗口持续时间(没有滑动间隔)时，如下所示：
10分钟
输入时间(2019-02-28 22:33:02)
形成的窗口为(2019-02-28 22:30:02) to (2019-02-28 22:40:02)
8分钟
输入相同的时间(2019-02-28 22:33:02)
形成的窗口为(2019-02-28 22:26:02) to (2019-02-28 22:34:02)
5分钟
输入相同的时间(2019-02-28 22:33:02)
形成的窗口为(2019-02-28 22:30:02) to (2019-02-28 22:35:0
浏览 1提问于2021-01-26得票数 1
回答已采纳
我正在寻找一种方法，将关闭时间记录的数量作为一个总计数，并从开放时间记录的数量中减去一个总计数，以便能够找到关闭票的百分比。
为了进一步解释，每一张票都有一个以DateTime格式打开的时间。当票证关闭时，将以DateTime格式在数据源中输入关闭时间。因此，我想找出票的百分比，是开放的，现在已经关闭。
试着用
SUM(COUNT_DISTINCT(OPEN TIME) - COUNT_DISTINCT(CLOSED TIME))
若要创建差异，但得到一个“不支持重新聚合度量”的错误。使用像Date_Diff这样的工具只会给我一张票在二维之间的时间，而不是记录的总数，这样我就可以转换成一个百分
浏览 1提问于2022-03-11得票数 -1
回答已采纳
我有一个用例，我需要对滑动窗口上的一列(让我们称之为X)进行百分位数的计算。因此，窗口定义是按时间顺序排列的-持续120天： days = lambda i: i * 86400
w = Window.partitionBy("entityId").orderBy(F.col("trn_time").cast("long").asc())
.rangeBetween(-days(120),-days(1)) 我考虑过使用approxQuantile，但它是一个数据帧函数。第二种选择是使用： percent_rank().over(w)
浏览 53提问于2020-06-30得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
