R中的时间聚合
是指将时间序列数据按照一定的时间间隔进行分组，并对每个时间间隔内的数据进行统计或计算。时间聚合可以帮助我们更好地理解和分析时间序列数据的趋势和周期性。
在R中，常用的时间聚合方法包括：
- 时间桶聚合（Time Bucket Aggregation）：将时间序列数据按照固定的时间间隔划分为不同的时间桶，然后对每个时间桶内的数据进行聚合操作，如求和、平均值等。时间桶聚合可以用于分析时间序列数据的趋势和周期性。
- 滚动窗口聚合（Rolling Window Aggregation）：将一个固定大小的滚动窗口应用于时间序列数据，窗口会随着时间的推移滑动，并对每个窗口内的数据进行聚合操作。滚动窗口聚合可以用于计算移动平均值、移动总和等指标，以便更好地捕捉时间序列数据的变化。
- 时间周期聚合（Time Period Aggregation）：将时间序列数据按照一定的时间周期进行分组，如按天、按周、按月等，然后对每个时间周期内的数据进行聚合操作。时间周期聚合可以用于分析时间序列数据的季节性和周期性。
- 时间间隔聚合（Time Interval Aggregation）：将时间序列数据按照不同的时间间隔进行分组，如按小时、按分钟等，然后对每个时间间隔内的数据进行聚合操作。时间间隔聚合可以用于分析时间序列数据的短期波动和变化。
在R中，可以使用一些包和函数来实现时间聚合，如：
dplyr包中的group_by()和summarize()函数可以实现时间桶聚合和滚动窗口聚合。lubridate包中的函数可以实现时间周期聚合和时间间隔聚合。xts包和zoo包提供了一些函数来处理时间序列数据，包括时间聚合操作。
对于时间聚合的应用场景，可以包括金融数据分析、销售数据分析、交通流量分析、气象数据分析等领域。通过时间聚合，可以更好地理解和分析时间序列数据的特征和规律。
腾讯云提供了一些与时间聚合相关的产品和服务，如：
- 腾讯云数据仓库（Tencent Cloud Data Warehouse）：提供了强大的数据分析和查询功能，支持对大规模数据进行时间聚合和统计分析。
- 腾讯云时序数据库（Tencent Cloud Time Series Database）：专门用于存储和分析时间序列数据，提供了高性能的时间聚合和查询功能。
- 腾讯云数据分析平台（Tencent Cloud Data Analytics Platform）：提供了丰富的数据分析工具和服务，支持对时间序列数据进行聚合和可视化分析。
更多关于腾讯云相关产品和服务的介绍，请参考腾讯云官方网站：https://cloud.tencent.com/
相关·内容
这是我的以下sql查询。
select a.job_name,endtime,to_char(endtime,'HH24:MI:SS') as endtime_1
from OPTOOLS.R11_JOB_PROD_VW a, OPTOOLS.R11_JOB_RUNS_PROD_VW b
where
a.joid=b.joid and a.job_name in ('hh_p_hkc_isrs_gim_trd_ld_bx') and rownum <= 30
and status = 'SUCCESS'
浏览 1提问于2012-02-16得票数 0
1回答
当我在涌入的web前端中探索我的数据时，所有的数据点都均匀地分布在10秒的步骤中。(12:00:00，12:00:10，12:00:20，...) 当我在Grafana面板中使用相同的查询时，时间会稍微变化1-2秒。(12:00:01，12:00:12，12:00:21，...) 如何才能强制Grafana面板保留10个步骤？ from(bucket: "my_bucket")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["_m
浏览 104提问于2021-11-12得票数 0
回答已采纳
1回答
通过使用不同的参数对应用程序进行基准测试，我获得了3组测量结果。每个测试运行的时间相同，但时间戳不同。我想画出相互重叠的结果。
结果存储在csv文件中，格式如下:时间戳，持续时间。我读取pandas数据帧中的结果，将时间戳转换为日期时间，并进行聚合以计算我想要显示的p90rt (代码如下)
df["timestamp"] = pd.to_datetime(df["timestamp"], unit='ms')
df.set_index("timestamp", inplace=True)
gdf = df.groupby(pd.G
浏览 6提问于2020-05-29得票数 0
回答已采纳
2回答
当我在中执行以下查询时，它产生了一个错误。
查询：
select u.UserName, r.RoleName
from User u
join UserRole ur on ur.UserId = u.UserId
join Role r on r.RoleId = ur.RoleId
group by r.RoleName
错误：
Msg 8120、级别16、状态1、第2列'User.UserName‘在select列表中无效，因为它既不包含在聚合函数中，也不包含在GROUP BY子句中。
有一段时间我使用了sql，我认为这是一些基本的命令。但我还是找不出原因。
注意：
浏览 0提问于2013-07-31得票数 1
回答已采纳
目前，我有一个ES查询，它提供了一个使用geohash_grid和date_histogram的"geo桶“列表。
"aggregations": {
"zoomedInView": {
"filter": {
"geo_bounding_box": {
"location": {
"top_left": "-37, 140",
"bottom_right": "-38, 146"
浏览 2提问于2016-05-23得票数 0
回答已采纳
我有以下查询，哪个查询按主键主机I分组，然后按提供的时间间隔分组。我希望将聚合和命中限制在两个datetime对象提供的时间范围内。设置大小限制了点击次数，但我不知道如何对聚合进行相同的操作，以及如何为两者设置全局日期范围？
SearchResponse<LogLine> response = await _elasticsearchClient.SearchAsync<LogLine>(r =>
{
r.QueryLuceneSyntax(request);
r.Aggregations(arr =>
{
arr.T
浏览 14提问于2022-08-23得票数 1
回答已采纳
1回答
我正在尝试用'zoo‘库加载R中的时间序列。
我的观察结果有不同的精度。有些有日/月/年，有些只有月和年，还有一些是年：
02/10/1915
1917
07/1917
07/1918
30/08/2018
随后，我需要按年、年和月对行进行聚合。基本的R as.Date函数不能处理这个问题。如何使用zoo对此数据进行建模？
谢谢你，穆隆
浏览 0提问于2013-06-15得票数 0
回答已采纳
2回答
我有一个包含大量数据集(~15M)的Neo4J数据库，我希望在其中一个属性上执行大于搜索的操作。我有相应的属性索引。属性是一个浮点值。
当我做一个像MATCH (i:Label) WHERE i.property = $value RETURN count(i)这样的精确匹配时，我会在很短的时间内得到结果。但是当我用greater than做同样的搜索时，也就是MATCH (i:Label) WHERE i.property > $value RETURN count(i)，它只需要很长时间。在Cypher中，正确的方法是什么？
编辑:执行计划：
+-------------------
浏览 6提问于2015-09-11得票数 3
回答已采纳
我有一台SQL SERVER 2008R2标准版。立方体有一个叫做"AUM“的度量值。基本上，这个衡量标准在一个维度的投资组合中只是累加的。
在时间上，我需要选择LastChild，在安全性上，我需要选择Max，在投资组合中，我需要选择SUM。
如何创建度量值？要实现所有3种类型的计算，聚合属性应该是什么。
目前，我们已经为安全性和覆盖默认SUM行为的时间编写了作用域声明。这很有效，但是随着安全和时间维度中成员的增加，SSRS报告查询会变慢很多。
我目前正在通过更改聚合的属性和一些额外的create member语句的组合来测试创建新的持久化度量，看看是否可以避免范围语句。
任何形式的
浏览 0提问于2014-07-17得票数 1
2回答
我已经在Microsoft中建立了一个基于日志的警报。部署通过ARM模板完成的警报。您可以在其中输入查询并设置阈值，如下所示。
"triggerThresholdOperator": {
"value": "GreaterThan"
},
"triggerThreshold": {
"value": 0
},
"frequencyInMinutes": {
"value":15
浏览 2提问于2020-12-31得票数 0
1回答
我对具有40k个文档的集合进行了聚合查询。
{ aggregate: "REV_TABLE", pipeline: [ { $match: { r: { $lte: 1486066601 }, ISDI_ID: "17" } }, { $group: { _id: "$l", maxVer: { $max: "$r" } } } ] }
我有两个索引：{"r":1}和{"r":1，"ISDI":1}，后台索引是开着的。最初，当文档很小时，它通常需要不到100ms。现在，因为它在35
浏览 13提问于2017-02-04得票数 4
在我的图表数据中有一个叫做“时间”的度量。我想使用R创建一个计算字段，我已经成功地安装了RServe，我这样做：
SCRIPT_REAL('hour(.arg1) + minute(.arg1)/60 + second(.arg1)/3600 ', [time])
但我在tableau计算字段中得到了错误：
错误:当使用表计算函数或来自多个源的字段时，所有字段必须是聚合或常量。
ANy知道我做错了什么吗？谢谢。
浏览 4提问于2015-07-06得票数 1
1回答
我写了以下查询：
SELECT r.StartTime,
(CASE d.DayOfWeekendInd WHEN 'Y' THEN COUNT(*) END) as 'WEEKDAY',
(CASE d.DayOfWeekendInd WHEN 'N' THEN COUNT(*) END) as 'WEEKEND'
FROM t_fact_rit as r
LEFT JOIN t_dim_date d ON r.DateId=d.DATE_SK
GROUP BY r.StartTime, d.Day
浏览 0提问于2017-11-01得票数 1
回答已采纳
2回答
在R中有一个时间序列对象，如下所示
anom_tsUNAD <- ts(data, start=c(1922,1), frequency=12)
我想画出每个月的平均值，而不把它转换成数据帧。有什么建议吗？
谢谢
浏览 2提问于2015-08-10得票数 1
回答已采纳
2回答
我正在使用source('scriptname.R').在R中运行一个脚本
我想得到这个脚本的运行时间。
有人能告诉我我该怎么做吗？
浏览 4提问于2013-10-26得票数 6
回答已采纳
我有火花数据帧，其中几列2被命名为recorded_ts和ts。recorded_ts是日期时间值的字符串表示(格式为20180101101125)，ts是真正的时间戳。
当我打印出数据框内容时，recorded_ts和ts中的值之间存在一对一的匹配。
然后，我使用以下代码计算列的平均值
meanDF = pv \
.groupBy("p_id", "u_id", "r_id", "b_id", window("ts", "15 minutes", "1 minute
浏览 1提问于2018-05-01得票数 1
1回答
我试图在R中创建一个条形图，并根据日期时间的时间进行休息。下面是我正在处理的数据示例：
966,34,2013-12-27 06:48:20,219.0,921.423404575176661
966,26,2013-12-23 07:19:18,147.0,1997.267748145552894
966,18,2013-12-20 07:32:29,195.0,1569.149919735630304
966,11,2013-12-19 12:15:19,955.0,4780.830543328801945
前两列是我不感兴趣的I形式。第三列是datetim
浏览 2提问于2014-04-28得票数 0
回答已采纳
1回答
我想要帮助计算的日期和时间的差异，之间的每个单元，1，通过15的小时和分钟。
问题是ref不是对所有的单元格都一样，所以当ref从R001变为R002时，公式应该开始计算来自第一个单元格的日期时间差，并使用对具有相同ref的最后一个单元格的新引用。
浏览 0提问于2018-03-31得票数 0
我有一个与此类似的数据集：
{"user":333,"product":943, "rating":2.025743791177902, "timestamp":1481675659}
{"user":333,"product":3074,"rating":2.1070657532324493,"timestamp":1481675178}
{"user":333,"product":3074,"rating":2.10
浏览 4提问于2016-12-14得票数 0
回答已采纳
1回答
我是这个论坛的新手，不好意思，如果我一开始就没有回答好我的问题。我已经在论坛上进行了研究，以找到我的问题的答案，但我还没有找到一个适当的解决办法。我有一个k个时间序列的数据集，如果我把一个时间序列作为参考，我试着将其他时间序列和参考序列进行比较，以便找出它们中的哪一个与参考序列相似。我正在使用的方法，如LCSS，ERP，EDR，DTW，但最终我有一些问题。时间序列不是等长的，所以每一种方法都没有给我所有类似的时间序列，因为它的长度不同。我正在寻找一种将不同长度的时间序列转换为唯一长度的方法。我怎样才能在R中做到这一点？
浏览 2提问于2018-06-21得票数 1
2回答
如何从YouTube中读取XML？我尝试了以下方法。
$xml = new XMLReader();
$xml->open('http://gdata.youtube.com/feeds/api/videos/1uwOL4rB-go');
$r = array();
while($xml->read()) {
$r[] = array($xml->name => $xml->value);
}
我走了这么远，但它没有得到我需要的必要信息，如视频持续时间。
浏览 0提问于2010-02-07得票数 3
回答已采纳
1回答
我有一个这样的数据框：
ID A B C D
1 1 0 x1 y
1 0 0 x1 y
1 0 0 x1 y
2 0 0 x6 v
2 0 1 x6 v
2 0 0 x6 v
3 0 1 r5 t
3 1 0 r5 t
3 0 0 r5 t
列ID是唯一的，我想通过显示max或sum来删除所有重复和聚合的列A和B(对于列A或B中的每个ID，最多只能有一个'1‘)，并显示对所有唯一ID具有相同值的列C和D。
ID A B
浏览 3提问于2016-07-26得票数 0
我正在将我的InfluxDB1.8版本迁移到InfluxDB2.0，我正在使用influxDB2.0数据库，并使用grafana来显示结果。我插入的数据是我的P1仪表的结果，虽然结果是总值，但我想要计算和显示每天的结果。正在插入的是当前(气体使用量)值。通过计算一天的开始和结束的差值，我得到了我的日常使用结果。 我确实找到了一种方法来做这件事一天。使用扩展函数。但我不会让它在超过1天的时间范围内工作。 ? 但现在要在更长的时间范围内将其显示在日常使用中。我没有找到正确的选项来获得这周的工作结果 ? 有谁有主意吗？ 查询1天： |> range(start: v.time
浏览 160提问于2021-06-14得票数 0
有了这些数据
d <- data.frame(time=1:5, side=c("r","r","r","l","l"), val = c(1,2,1,2,1))
d
time side val
1 1 r 1
2 2 r 2
3 3 r 1
4 4 l 2
5 5 l 1
我们可以像这样展开到一个整洁的数据帧中：
library(tidyverse)
d %>% spread(side,val)
这就给出了：
浏览 4提问于2018-01-25得票数 0
回答已采纳
流入2数据库存储来自机械计数器(气体计数器)的增量值。目标是构建一个查询，以获得某一时间间隔(例如某一天)的消耗。使用SQL，我将将数据分组到所需的间隔中，而不是计算该间隔的max() - min() +1。使用通量查询语言进行这一操作的首选方法是什么？
from(bucket: "Energy")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["_measurement"] == "gas")
|> filt
浏览 9提问于2022-02-07得票数 0
2回答
求和条件不包括没有正和的行
、、、、
我有一个奇怪的问题，在返回条件为true的行之和时，似乎只有在条件为真的情况下才返回行--或者至少排除了大部分否则会返回的行。
原始查询-返回所有行：
SELECT r.type, r.user1, r.user2, r.roomkey, r.name, r.active, m.active
FROM members as m
INNER JOIN rooms as r ON m.roomid=r.id
WHERE m.userid = ?
ORDER BY r.active DESC, m.active DESC
对于返回的每一行，我还希望获得另一个表中具有比我已经查询的时间戳更新的时
浏览 0提问于2020-05-09得票数 0
回答已采纳
2回答
我在找一些关于我的要求的建议。下面是对我的要求的描述。如有任何细节请随时与我联系。即使是一些关于如何更清楚地描述我的问题的建议也是非常感谢的：)
需求描述
我有一些数据，格式如下：router, interface,timestamp, src_ip, dst_ip, src_port, dst_port, protocol, bits r1, 1, 1453016443, 10.0.0.1, 10.0.0.2, 100, 200, tcp, 108 r2, 1, 1453016448, 10.0.0.3, 10.0.0.8, 200, 200, udp, 100
如您所见，这是一些网络原
浏览 3提问于2016-01-18得票数 0
回答已采纳
让我们有以下数据
CREATE TABLE [dbo].[LogTable] ([DateSent] [datetime] NULL)
GO
CREATE CLUSTERED INDEX [IX_LogTable_DateSent] ON [dbo].[LogTable] ([DateSent] DESC)
GO
INSERT INTO [LogTable]
SELECT TOP 500000 NULL, DATEADD(day, ( ABS(CHECKSUM(NEWID())) % 65530 ), 0)
FROM sys.sysobjects
CROSS JOIN sys.all_c
浏览 2提问于2017-09-04得票数 0
回答已采纳
1回答
我在另一个线程上提出了一个问题。但我得到了一个不完整的答案。没有人愿意回答。这就是我提出另一个修改问题的原因。让我简单地解释一下这个问题，我想重述以下数据：
**`
Timestamp L_x L_y L_a R_x R_y R_a
2403950 621.3 461.3 313 623.3 461.8 260
2403954 622.5 461.3 312 623.3 462.6 260
2403958 623.1 461.5 311 623.4 464 261
2403962
浏览 3提问于2015-11-06得票数 3
回答已采纳
1回答
我们创建了以下查询，以便将稀疏的时间序列数据转换为具有特定时隙的密集数据。其思想是将时间范围(例如1小时)转换为不同的时隙(例如，60x1分钟时隙)。对于每个插槽(在本例中为1分钟)，我们计算是否有一个或多个值，如果存在，则使用一个最大值函数来得到我们的值。如果在时间范围内没有值，则使用前一个时隙中的值。
下面是基本的查询：
WITH readings AS (
(
-- Get the first value before the time window to set the entry value
SELECT
timestamp AS timestamps
浏览 5提问于2021-10-26得票数 0
回答已采纳
我可以看到，星火流窗口功能只基于“接收数据时”进行分组。我想根据数据本身中可用的时间戳字段进行分组。有可能吗？
例如，数据创建时间戳作为1 PM数据的一部分可用。但是火花流在下午1.05就收到了数据。因此，它应该根据数据中可用的时间戳(1PM)进行分组。
浏览 0提问于2017-08-17得票数 1
我的目标是复制一个Drupal 6站点到一个新的主机，但我有一些问题。
New host - 198.20.226.199/~paul8226/ -- No name resolution setup yet.
Old host - www.egcasting.com/
我使用与我现有站点相同的数据库名、用户名/密码在新的Host帐户上执行了一个新的Drupal 6安装(干净的URL正常工作)。然后，我从现有站点导入数据库，并复制了sites/default (settings.php除外)和所有站点/ all。它看起来像网站的全部功能，除了主题是没有样式的任何东西。
Google C
浏览 0提问于2013-05-14得票数 1
回答已采纳
1回答
我是Ada的新手，我尝试创建一个记录数组，然后将一些记录放到数组中，但是我得到了错误的nested array aggregate expected。这是我的代码：
with Ada.Text_IO; use Ada.Text_IO;
with Ada.Integer_Text_Io;
with Ada.unchecked_conversion;
procedure main is
type Byte is range 0..255;
for Byte'Size use 8;
type Pixel is record
R:Byte;
G:Byte;
浏览 3提问于2014-10-02得票数 0
回答已采纳
1回答
将函数应用于列值的组合
、、、
这是一个数据帧，包含P，G，A：
P G A
C2 28 R0
C2 35 R1
C2 30 R0
C2 33 R0
C2 30 R0
C7 31 R1
C7 25 R1
C7 23 R1
C7 28 R0
C7 22 R0
C8 22 R1
C8 23 R1
C8 25 R0
C8 30 R1
C8 33 R0
C8 27 R0
有没有一种简单的方法可以得到每个P中每个A的G的平均值？这是对于C2，我想要A，==，R0，G的平均值。我只能对一个分组使用aggregate，但不知道如何管理组合的两个或多个分组。
浏览 0提问于2016-04-26得票数 0
如何在幽门流中引用当前的data.frame？例如，在
library(dplyr)
myresults = tribble(
~dataset_name, ~method_group, ~method, ~value,
'iris', 'other', 'a', 1,
'wine', 'other', 'b', 2,
'iris', 'mine', &#
浏览 1提问于2018-09-22得票数 3
回答已采纳
2回答
我正在为我工作的公司构建一个闪亮的仪表板，它显示了公司的关键指标。仪表板当前加载速度相当快，但随着时间的推移，仪表板的速度越来越慢，因为我正在查询的数据库中的表(为此使用RMySQL )越来越大(随着时间的推移，它正在收集更多的数据)。
我已经尽了最大努力使SQL查询快速运行(使用索引列、重新分区等)，但这只是到目前为止。查询数据后，仪表板需要处理该数据，由于数据大小的增加，数据的处理速度也会随着时间的推移而减慢。
有什么办法可以解决这个问题吗？我的一位工程师建议在R中使用Ajax函数，这将允许仪表板一开始只加载一部分数据(即。过去两个月)足够填充仪表板的图表，在后台将继续加载其余的数据(在一
浏览 0提问于2018-07-09得票数 0
回答已采纳
当你想在python中根据时间戳对数据进行重采样时，pandas的重采样函数很容易使用。例如，从一个以秒为单位的时间戳的dataframe1到另一个重采样到10分钟的平均值。
df1_10m=df1.resample('10T', how='mean')
现在我需要在matlab中做同样的事情，但我没有找到一种明确的方法。
函数重采样似乎是另一回事。
我尝试了重塑，但我得到了错误。
function[Data_10mean]=resamp(table)
table.ts=datestr(table.ts); % format the time stamp
Tab
浏览 3提问于2016-07-02得票数 1
我需要从一个特定的时间到最近一轮的令牌链的价格。此时间根据用户输入而变化，但根据令牌的心跳，窗口相对较短(最多为1天至2周)。它用于计算智能合同和应用程序主页中的支出价格。
要获得历史价格数据，Chainlink需要一个'roundId‘，这是一个非增量的价值。
从Chainlink获取给定时间窗口的所有roundIds，或者以打开、分散和可以在可靠的智能契约中访问的方式记录它们，最好的方法是什么？
浏览 10提问于2021-12-16得票数 3
回答已采纳
我被要求做一个报告，它结合了我们使用的3种不同的水晶报告。这些报告已经非常缓慢和沉重，使一个大的一个是不可能的。所以我在VS 2010中创建了一些应用程序。
我的主要问题是，我有3个Datatable (相同的模式)，它们是用Dataset designer创建的，我需要将其组合起来。我创建了一个空表来存储合并的值。查询已经相当大，因此将它们合并到SQL查询中是不可能的。
另外，我没有对SQL服务器(2005)的写访问权，因为服务器是由创建我们的MRP程序的公司维护的。虽然我总是可以请求支持将视图添加到服务器。
因此，我的3个数据表包括人工成本、材料成本和分包成本。我需要创建一个总成本表，根据
浏览 3提问于2010-09-15得票数 0
1回答
我想确定与认识特定人的邻居的交谈持续时间的相对百分比。
neo4j-sh (0)$ start a = node(351061) match (a)-[r:TALKED_TO]->(b) return sum(r.duration)
==> +-----------------+
==> | sum(r.duration) |
==> +-----------------+
==> | 12418 |
==> +-----------------+
==> 1 row, 0 ms
neo4j-sh (0)$ start a =
浏览 0提问于2012-10-01得票数 0
回答已采纳
1回答
我当然可以用钢笔和计算器来完成这个任务，但我认为在R中这样做是有意义的。我已经用Rmisc为我的数据生成了一个包含各种手段、sd、se和ci的表格。
summarySE(data=Chloro，"ChlorophyllSq"，groupvars =c(“治疗”，“时间”)，conf.interval = 0.95)
我有三个自变量(治疗(4个因素)，时间(5个因素)和深度(2个因素)。
有没有办法找出不同处理不同时间点之间叶绿素平均值的百分比变化？在不同的处理(1,2,3,4)中，我想找出叶绿素在1，2，3，4处理中的时间点1和5(最后一个时间点)的差异。
然后，我可能有兴
浏览 3提问于2020-04-19得票数 0
1回答
我正在尝试编写一个查询，该查询将从一个值列表中提取“最佳”记录：
SELECT s.swimmerName, r.resultTimeText, r.resultAgeGroup, r.resultEventID, v.venueName
FROM tblResults r
JOIN tblEvents e ON e.eventID = r.resultEventID
JOIN tblSwimmers s ON r.resultSwimmerID = s.swimmerID
JOIN tblVenues v ON e.resultVenueID = v.venueID
WHERE s
浏览 4提问于2014-01-09得票数 1
回答已采纳
我有以下代码超时：
using (var ts = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = System.Transactions.IsolationLevel.ReadUncommitted }))
{
ECWSDataContext dc = new ECWSDataContext();
IQueryable<Ticket> results = d
浏览 5提问于2012-03-15得票数 1
我试图使用Flink 1.3.2进行第二层聚合，但我的结果似乎没有像预期的那样随着时间的推移而执行。一开始，我得到了预期的结果。
我在这里采取的方法有什么根本问题吗？
我还没有找到任何其他人执行这种链式操作的好例子。
val myStream = sourceStream
.keyBy( 0 )
.timeWindow( Time.minutes(30) )
.reduce( (r1: myRow, r2: myRow) => { r1 + r2 },
(key: Any, window: TimeWindow, iterable: It
浏览 1提问于2017-09-29得票数 0
回答已采纳
我有两个数据格式如下：
+--------+----------+------+-------------------+
|readerId|locationId|userId| timestamp|
+--------+----------+------+-------------------+
| R2| l1| u2|2018-04-12 05:00:00|
| R1| l1| u1|2018-04-12 05:00:00|
| R3| l3| u3|2018-04-12 05:0
浏览 0提问于2018-04-17得票数 2
回答已采纳
我用GetStream创建了一个安装程序，其中我有一些包含数据的平面提要和一个在平面提要之后的聚合提要。
现在，我从我的数据库中将数据上传到平面提要，并将自己的时间戳添加到活动中。让我按时间定单。
这里是我的问题:当我使用聚合提要跟踪平面提要时，聚合提要似乎是按照上次更新的活动排序的。我想用我的时间戳来分类。
我的问题:我是否可以按照自己的时间戳对聚合提要进行排序？
浏览 1提问于2018-09-05得票数 2
1回答
我对InfluxDB很陌生。我有一个用20 the收集数据的应用程序，它被写入数据库。
在某种程度上，我需要查询/显示这些数据。目前，我通过以下方式实现这一目标：
from(bucket: "test-bucket")
|> range(start: 0; stop: now())
|> filter(fn: (r) => r["_field"] == "sensorValue")
|> aggregateWindow(every: 1s, fn: mean, createEmpty: false
浏览 25提问于2022-11-17得票数 0
假设我有一个带有时间戳字段的mongo集合中的文档。我想根据时间戳值(大于、小于)查询文档。为了做到这一点，我希望在查询中嵌入从日期到时间戳的转换，而不是每次都计算当前日期的时间戳。我尝试了这样的方法(假设"ts"是我的时间戳字段)： db.my_collection.find({"ts": {$lt: {$toLong : new Date("2020-12-09")}}}) 而不是做： db.my_collection.find({"ts": {$lt: 1578524400}}) 但它似乎返回了一个空结果。 在查询中是否有
浏览 113提问于2020-12-09得票数 0
我正在使用R分析从40,000多个事件中收集的365天的数据。这些事件发生在一天中的不同时间。我希望以不同的时间间隔汇总事件并计算平均值，例如2小时、8小时、12小时或每天。我见过使用CUT和AGGREGATE，但它似乎没有提供所需的间隔。
任何建议都将不胜感激。
浏览 13提问于2016-08-03得票数 0
回答已采纳
2回答
我在Tableau遇到了一个问题，希望有人能帮我，我很感激！
一个我在Tableau中无法解决的问题的简单例子：
Payment Customer Amount
1 BMW 20000
2 VW 30000
3 BMW 1000
4 VW 5000
5 VW 6000
这必须在客户级别上进行聚合，并且必须如下所示：
Customer Amount
BMW 21000
VW 4100
浏览 0提问于2013-12-11得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
