按时间窗口之间的时间间隔分组
是一种将时间序列数据按照指定的时间间隔进行分组的方法。通过将时间序列数据划分为不同的时间窗口，可以更好地理解和分析数据的变化趋势。
这种分组方法在很多领域都有应用，例如金融领域中的股票交易数据分析、物联网领域中的传感器数据处理、网络流量分析等。
在云计算领域，按时间窗口之间的时间间隔分组可以用于实时数据处理和分析。通过将实时产生的数据按照时间窗口进行分组，可以对数据进行聚合、统计和分析，从而得出有价值的信息和洞察。
腾讯云提供了一系列适用于按时间窗口分组的产品和服务，包括：
- 云原生数据库TencentDB：TencentDB是腾讯云提供的一种高性能、可扩展的云数据库服务。它支持按时间窗口进行数据分组和聚合，可以方便地进行实时数据处理和分析。
- 云函数SCF（Serverless Cloud Function）：SCF是腾讯云提供的无服务器计算服务，可以根据事件触发自动运行代码。通过编写自定义的函数，可以实现按时间窗口分组的数据处理逻辑。
- 数据湖分析Datalake Analytics：Datalake Analytics是腾讯云提供的大数据分析服务，可以对海量数据进行快速查询和分析。它支持按时间窗口进行数据分组和聚合，适用于处理大规模的时间序列数据。
以上是腾讯云提供的一些适用于按时间窗口分组的产品和服务，可以根据具体需求选择合适的产品进行数据处理和分析。
相关·内容
TimeWindowCompactionStrategy背后的想法是每个SSTable只有一个特定时间窗口的记录，而不是来自不同时间窗口的记录相互混合。
水平压实不会产生类似的结果吗？SSTables与来自同一级别的其他SSTables压缩，它们都来自相同的时间窗口。(也就是更高级别的SSTables总是更老)。这看起来与DateTieredCompactionStrategy非常相似，除了SSTable大小是由最大大小(MB)而不是时间窗口确定的。
浏览 0提问于2017-08-03得票数 1
2回答
使用下面的代码格式化编号234156.123的模式#，##，###.###被格式化为234,156.123，但是它应该被格式化为2,34,156.123
小数位按模式排列，而小数点之前的数字不是预期的格式。
编写的代码如下
String pattern = "#,##,###.###";
double number = 234156.123;
DecimalFormat decimalFormat = new DecimalFormat(pattern);
String format = decimalFormat.format(number);
System.out.prin
浏览 2提问于2015-06-22得票数 4
1回答
时间循环平均值
、、
我有一个包含17,000条记录的表，该表按15分钟间隔的时间间隔排序。时间值每24小时循环一次，例如，我可能有100条记录都在凌晨1点，只是在不同的日期。我想通过在凌晨1点获取这100条记录并找到它们在平均凌晨1点的平均值来创建“平均一天”
我不知道如何格式化表格，让它在这里很好地显示出来。
浏览 2提问于2016-10-19得票数 0
我想知道是否有可能有一个时间框架的公式。例如:我有一个Excel文件，关于一天中不同时间收到的一些电子邮件。因此，我将按半小时的时间框架对它们进行重新分组。(12 AM t0o 12H29 AM、12H30 AM至12H50 AM等)。因此，如果电子邮件是在中午12点05分收到的，它将在上午12点到12点20点之间发送如果一个在下午1:10到来，则在下午1:00-1:9之间有可能吗？
非常感谢
浏览 5提问于2015-02-04得票数 0
我有一个包含date属性的模型。
我可以将日期按Dictionary(grouping..分组
let grouped = Dictionary(grouping: orders.results, by: { $0.createdAt })
但问题是在解码的时候我这么做了：
let dateFormatter = DateFormatter()
dateFormatter.locale = Locale(identifier: "en_US_POSIX")
dateFormatter.dateFormat = "yyyy-MM-dd'T'HH:mm:ss
浏览 0提问于2018-06-14得票数 5
回答已采纳
3回答
我使用MongoDB2.6。我已将我的数据存储在以下表格中：
{
"_id" : "my-sensor-1",
"points": [
{ "timeStamp" : NumberLong("1453468362174"), "value" : 41 },
{ "timeStamp" : NumberLong("1453468483297"), "value" : 66 },
{
浏览 11提问于2016-01-22得票数 6
回答已采纳
1回答
我在共享自行车上有一个df，其中有600 k行的信息，每分钟都有更新数据的7天的信息，我需要计算一个时间跨度的概率。df的一个例子：
Name NrBikes Data Time MaxBikes TotalDocks Probability
A 16 2020.10.01 01:00:00 x 26 y
B 16 2020.10.01 01:01:00 x 26 y
...
C 8 2020.10.01 02:00:00 x 26 y
...
D 14 2020.10.01 03:00:00 x 26 y
我需要的是x和y的值，其中x指行时间到-1/+1小时之间的最大"NrBikes
浏览 0提问于2020-10-19得票数 0
回答已采纳
我有一个有多列的data.frame。其中一列是time，因此不是递减的。其余的列包含在data.frame的特定行中指定的时间指定的时间记录的观测值。
我想选择一个时间窗口，比如"x“秒，并计算该窗口的同一data.frame中其他列中条目的平均值(或任何函数)。
当然，因为它是基于时间的平均值，所以窗口中的条目数量可以根据数据的不同而不同。这是因为属于某个时间窗口的行数可以改变。
我使用了一个自定义函数来完成此操作，该函数将在data.frame中创建一个新列。新列为时间窗口中的所有条目分配单个编号。该数字在所有时间窗口中都是唯一的。这实际上是根据时间窗口将数据分组。然后我使用R的
浏览 2提问于2010-10-21得票数 6
回答已采纳
我试图编写一个查询，以查找值在一定时间内相同的实例。在大多数情况下，这种查询对于报告值为0或1的“元数据”度量非常有用。
在我的例子中，我感兴趣的是一个度量是否有20分钟的值1。我的方法是随着时间的推移得到最小值，就好像时间序列在20分钟窗口内有一个单一的0值一样，它将报告为0。
min_over_time(meta_metric[20m]) > 0
除了创建新时间序列的实例外，这在大多数情况下都能很好地工作。在这些情况下，如果时间序列以值1开头，则会导致时间序列在整个20分钟内的值为1，因为窗口中的所有其他值都为null。
是否有任何方法将空值默认为0或忽略缺少值的窗口？
浏览 2提问于2021-12-20得票数 2
我有一个具有以下模式的df：
ts: TimestampType
key: int
val: int
df按ts的升序排序。从行(0)开始，我想在特定的时间间隔内对数据进行分组。
例如，如果我说df.filter(row(0).ts + expr(INTERVAL 24 HOUR)).collect()，它应该在第(0)行的24小时时间窗口内返回所有行。
在Spark上下文中是否有实现上述目标的方法？
浏览 2提问于2016-02-18得票数 0
回答已采纳
出于某种奇怪的原因，group by week返回带有日期时间字段的奇数日期间隔。
"Completed“是一个日期时间字段，使用以下查询：
SELECT
Completed,
COUNT( DISTINCT Table1.ID ) AS ActivityCount
FROM Table1
JOIN Table1Items
ON Table1.ID = Table1Items.ID
JOIN database_database.Table2
ON Table2.Item = Table1Items.Item
WHERE Completed != '
浏览 2提问于2012-10-26得票数 0
首先，我道歉，我甚至不知道从哪里开始，并没有找到任何具体的具体问题。
我有一个有日期时间(开始和结束)的表，我需要找到一种方法在这些天之间获得分钟/小时。它既可以是工作日的时间之和，也可以是每一天的某种枢轴，并按ID号分组。我曾经想过给天数分配一个值，但是时间是随机的，不会在午夜开始/结束，所以我对如何处理这个问题感到茫然。
下面是一些日期/时间格式的例子，如果这有帮助的话。
2018年开始-12-14 10:53:01
2018-12-27 11:50:00
任何帮助或提示都将不胜感激！
编辑
忘记包括我正在使用SQL Server (SSMS)
编辑以获得更多澄清
这里有一个带有ID号的示
浏览 3提问于2019-01-08得票数 0
假设我在时间上有离散的事件，例如病人生病，我想预测这些事件是否是其他潜在事件的指标，例如疾病爆发。通常情况下，人们会将基于事件的时间序列转换为一个规则的时间序列，例如，将每周患者的数量进行汇总。然而，我觉得这种聚合会丢失很多信息，而且也很难利用事件的多重特征，例如病人的年龄、病人的性别等。我的问题很笼统:是否有统计学/数据科学的分支，在任意时间将时间序列视为由事件组成，而不是按均匀分布的时间间隔聚集值？
我试着在谷歌上搜索，但似乎很难用搜索引擎理解的方式表达这个问题。
浏览 0提问于2018-11-14得票数 1
回答已采纳
我在Kafka中有这样的数据：
{
"account": "iOS", //Possible values: iOS, android, web, windows
"events": [
{
"timestamp": "2017-07-03T20:19:35Z"
}
]
}
时间戳从2017-07-03T20:19:35Z到2017-07-03T20:22:30Z (大约3分钟)。我有这个Flink程序，它从上面的kafka主题中摄取数据：
object TestWindow
浏览 31提问于2017-07-04得票数 1
回答已采纳
我正在运行Elasticsearch v1.2.2。
我收集了像这样的文件
[
{ id: 1, source: { host: 'test.localhost', timestamp: 1407937236, loading_time: 2.841917 } },
{ id: 2, source: { host: 'test.localhost', timestamp: 1407937262, loading_time: 2.009191 } },
{ id: 3, source: { host: 'test.localhost',
浏览 1提问于2014-08-15得票数 1
回答已采纳
所以我有要分析的销售数据。我有日期时间数据“订单日期时间”，我想看看最常见的销售小时，但更重要的是，我想看看哪些分钟没有销售。 我已经转了一段时间了，但我的大脑无法找到解决方案。任何帮助都是非常感谢的。 我导入数据： df = pd.read_excel ('Audit Period.xlsx')
print (df) 我清理数据： # Remove all columns except `applieddate` and null rows
time_df = df[df["Order Date Time"].notnull()]
# Ensure the
浏览 28提问于2021-09-22得票数 1
1回答
我正在处理一组时间序列数据。我把它按时间分成108个窗口(一个时间窗口是一个月长的)。然后我为每个窗口绘制了一个直方图。所以我有108个直方图，从time window1到window108，它们是按时间顺序排列的(从2006年11月到2015年10月，108个时间窗口)。
我想做的是:把这108个直方图画成一个水平长的直方图。所以就像把它们加在一起一样。例如，为window1绘制直方图，在没有任何空白的window1直方图之后，需要对window2和3、4、5、6、直到窗口108进行直方图。我如何在Python中做到这一点？
浏览 3提问于2016-03-07得票数 0
回答已采纳
1回答
我在我的程序中使用ajax timer进行在线测试应用程序。程序按预期工作。
然而，Ajax计时器也在计算页面加载时间。例如，如果我为一个问题分配20秒，在页面加载后，用户将获得少于20秒的时间，因为它将计算加载时间。
有没有什么方法可以禁用计时器，并在整个页面加载后再次启用它。或者是否有任何C#代码来确定页面是否完全加载？？
谢谢，吉图
浏览 2提问于2011-07-29得票数 0
回答已采纳
1回答
一种寻找通信网流量频率的算法
、、、、
我正在编写一种算法，通过它在一天内通信的频率来识别异常的网络流量。例如，能够检测恶意软件的特点，它的信标定期回家，这是不同的正常用户的流量。
我正在寻找的特征*信标回家定期*信标回家的时间比正常用户更长的时间是活跃的，等等。
这有点困难，因为很多可能被恶意软件感染的用户都隐藏在防火墙后面(他们有相同的IP地址)。似乎我可以应用FFT来搜索数据集中的特定频率，但我还没有在网上找到任何类似的搜索。
我拥有的数据包括*划时代时间(出站通信发生的第二次)*用户IP地址*目标URL
下面是一个例子。在顶部，您可以看到一天中的每一秒，恶意软件试图在24小时内定期地恢复(在这种情况下，每天大约2k次，可能是
浏览 3提问于2014-02-27得票数 2
回答已采纳
2回答
我有一个事件表，它是由站点上的用户活动生成的：
timestamp | name
7:00 AM | ...
7:01 AM | ...
7:02 AM | ...
7:30 AM | ...
7:31 AM | ...
7:32 AM | ...
8:01 AM | ...
8:03 AM | ...
8:05 AM | ...
8:08 AM | ...
8:09 AM | ...
我想对事件进行聚合，以提供用户何时处于活动状态的视图。我将活动定义为事件在+/- 2分钟内的时间。就以上情况而言，这意味着：
from | till
7:00
浏览 5提问于2017-02-22得票数 1
回答已采纳
3回答
我试图用日期时间字段将记录分组为90分钟一次。
我可以按任何时间分组，其中60分钟可以通过以下方法均分：
SET @Interval = 3 -- Every 3 Minutes
SELECT CAST(
CONVERT(VARCHAR(8), [TIME_STAMP],112) + ' ' +
CONVERT(VARCHAR(2), DATEPART(hh, [TIME_STAMP])) + ':' +
CONVERT(VARCHAR(2), DATEPART(mi, [TIME_STAMP]) / @
浏览 7提问于2015-04-16得票数 1
回答已采纳
我目前遇到了一个问题，我想在我的csv上使用窗口和滑动间隔，并对每个窗口执行数据聚合以获得最常见的类别。但是，我没有时间戳，我想在索引列上执行窗口滑动。有谁能告诉我如何在索引上使用窗口+滑动间隔的正确方向吗？
简而言之，我想在索引列上创建windows+intervals。
目前我有这样的东西：
schema = StructType().add("index", "string").add(
"Category", "integer")
浏览 1提问于2021-07-10得票数 0
在水晶报告中，我想显示时间对象的和值，即雇员在一个月内工作三天，而在每一天都有可变的小时数。
是否有一个时间场之和？
或者，作为一种解决办法，我可以使用时间字段作为整数，将其和起来并显示出来。但是，我想通过使用公式来改变显示格式。我找不到在公式中包含摘要字段的方法.
提前感谢
PS我正在使用CR 2011 (只是程序，而不是通过VB或任何东西)。
浏览 3提问于2011-10-12得票数 1
回答已采纳
我有收藏，其中存储数据与时间戳。我希望这样做，比如以z分钟为间隔获取从日期x到y的集合中的每条记录。那么我如何在单个查询中做到这一点呢？
浏览 4提问于2016-09-12得票数 0
1回答
问题是:有一个数值流。值是以脉冲方式推入的，因此100个值可以非常接近彼此(按时间顺序)，即每5-10毫秒，然后它可能会停止一段时间，然后突发again.The的概念是显示最长为500 ms的窗口的累积值(和)。
我的第一次尝试是使用缓冲区( 500 ms)，但是这会导致事件的持续抽吸(每500毫秒)，其之和为0(作为累积的缓冲区项os 0)，可以用空缓冲区过滤来修复它，但我真的想完全避免这种情况，只有在一个值在“沉默”一段时间后才打开缓冲区。
附加限制:实现是UniRx，它不包含所有Rx操作符，特别是窗口(在这种情况下可能有用)，因此解决方案仅限于基本操作符，包括缓冲区。
浏览 2提问于2020-03-17得票数 0
回答已采纳
2回答
我在PostgreSQL 11中有以下“事务”表：
|=====================|==================|==================|===========================|
| owner | amount | category | timestamp |
|=====================|==================|==================|=====================
浏览 1提问于2020-10-24得票数 0
3回答
给定一个这样的数据集；
+-----+---------------------+--------+
| id | date | result |
+-----+---------------------+--------+
| 121 | 2009-07-11 13:23:24 | -1 |
| 122 | 2009-07-11 13:23:24 | -1 |
| 123 | 2009-07-11 13:23:24 | -1 |
| 124 | 2009-07-11 13:23:24 | -1 |
| 125 | 200
浏览 0提问于2009-07-11得票数 0
回答已采纳
我正在尝试使用DecimalFormat类格式化一个双数字。
我希望这是基于地区的印刷。
代码：
DecimalFormat df = new DecimalFormat("#####,###,###.00");
String result = df.format(99999999999.99);
System.out.println(result);
实际输出：
99,999,999,999.99
预期输出：
99999,999,999.99
浏览 3提问于2017-04-12得票数 1
我想知道在Apache中处理以下问题的最佳实践是什么。
我有一个喷口，它生成一个整数值流，并附加一个显式时间戳。目标是在此流上通过三个滑动窗口执行min/max聚合：
最后一小时
最后一天，即最后24小时
最后一个小时很容易：
topology.setBolt("1h", ...)
.shuffleGrouping("spout")
.withWindow(Duration.hours(1), Duration.seconds(10))
.withTimestampField("timestamp"));
浏览 5提问于2017-05-04得票数 0
回答已采纳
目前，我有一个带有登录凭据的网页，当提供适当的凭据时，允许用户登录。现在，在这个登录之后(验证是通过ajax调用Servlet完成的)，用户被重定向到不同的页面(具有不同的URL)。如何创建/管理会话？
我需要以下功能：
如果用户关闭了选项卡/浏览器窗口，则应该让用户退出。
此外，如果用户在很长一段时间内不生成任何活动(约15分钟)，则应自动注销用户。
注意:我不想依赖饼干。还有别的办法吗？
另外，我是否需要对服务器执行重复轮询？(这样，如果服务器在一段时间后没有收到请求，会话就会到期.)
浏览 3提问于2014-02-10得票数 1
回答已采纳
5回答
我正在制作一个网页，在其中我必须打开一个弹出窗口，它应该保持打开8秒(8000毫秒)的时间段。
在此时间段之后，应关闭该弹出窗口。然后再次在4秒后，我需要再次打开相同的弹出窗口8秒。
我想在弹出窗口自动打开和关闭之前放置一些延迟(4秒)，弹出窗口必须保持打开8秒
下面是我的代码：
<html>
<head>
<script>
function call()
{
popup = window.open('http://www.google.co.in');
浏览 2提问于2013-05-29得票数 4
回答已采纳
2回答
我无法理解kafka流中的groupBy/groupById和窗口的概念。我的目标是在一段时间内(例如5秒)对流数据进行聚合。我的流数据看起来类似于：
{"value":0,"time":1533875665509}
{"value":10,"time":1533875667511}
{"value":8,"time":1533875669512}
时间以毫秒为单位(时代)。在这里，我的时间戳在我的信息中，而不是在密钥中。我想平均值5秒窗口的值。
下面是我正在尝试的代码，但我似乎无法让它工作。
bu
浏览 0提问于2018-08-10得票数 7
我基本上想创建一个规则，帮助我以某种方式求解VRP (我正在针对距离进行优化)：
我希望它有时间窗口，这些规则工作正常：
// TIME WINDOW &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&
浏览 4提问于2015-03-07得票数 0
1回答
假设我有一个数据流，其中包含事件时数据。我希望在8毫秒的窗口时间内收集输入数据流，并减少每个窗口数据。我使用以下代码执行此操作：
aggregatedTuple
.keyBy( 0).timeWindow(Time.milliseconds(8))
.reduce(new ReduceFunction<Tuple2<Long, JSONObject>>()
Point数据流的关键是处理时间的时间戳映射到处理毫秒时间戳的最后8个子倍数，例如1531569851297将映射到1531569851296。
但是，数据流可能到达较晚，并进
浏览 2提问于2018-07-14得票数 1
回答已采纳
我们对在GAE中使用推送队列很感兴趣，但有一件事我找不到，那就是在队列或appengine宕机时的恢复窗口。
例如，我有一个包含多个任务的推送队列。其中一些任务被拉出并正在执行。现在假设当这些任务正在执行时，队列停止了(不管是什么原因)，然后又恢复了。恢复队列的时间窗口是什么？是否有固定的恢复时间窗口？
由于恢复时间窗口的原因，这些从队列中拉出并正在执行的任务可能会重新出现在队列中，并让它们再次执行。
我们在代码中考虑了幂等性，但如果知道GAE队列停机时间是否有时间窗口恢复策略，那将是一件好事。
浏览 3提问于2012-10-29得票数 1
回答已采纳
所以我用固定的启动时间制作了一个“时间流逝”时钟。所以，它从8点开始到18点，然后重复。每隔4秒，1小时就会过去。关于改进我的代码的任何其他建议也确实对我有帮助。提前谢谢你。
constructor(props) {
super(props);
this.state = {
minute: 0,
second: 0,
hour: 8,
leadingZero: 0
};
}
componentDidMount() {
this.timerClock = setInterval(() => {
浏览 1提问于2018-10-02得票数 0
回答已采纳
1回答
贪婪调度算法
、、
有一个证据表明，按任务开始时间对任务列表进行排序将使用执行任务所需的机器的最小数量。我发现一个案例，根据他们的总时间进行排序时，使用的机器较少。
调度方法:该算法利用来判断时间是否重叠。如果它们确实重叠，我们就制造一台新机器。如果没有，我们就重新分配机器。
private static void schedule(ArrayList<Task> tasks, ArrayList<Machine> machines) {
for (Task t : tasks){
boolean canProcess = false;
for(Ma
浏览 2提问于2015-11-21得票数 0
我有一个Apache管道，我想从Google PubSub主题中读取，应用去重复，并在15分钟固定窗口的末尾将消息发送到另一个Pubsub主题。但是，问题是信息似乎是立即被发送到主题上，而不是等待15分钟的结束。
即使在应用Window.triggering(AfterWatermark.pastEndOfWindow())之后，它似乎也不起作用(即立即发出消息)。(参考文献：)
在我的代码有什么问题上寻求帮助？完整代码如下：
另外，假设去重复以固定窗口作为其绑定是正确的，还是我需要单独设置去重复的时间域(Ref：似乎说它将默认为时间域，即定义的固定窗口)
pipeline
.apply(
浏览 19提问于2022-03-16得票数 0
我有一张桌子记录，叫它“游戏”
它有一个id和时间戳。
我需要知道的是，具体而言，它与表格无关。为了知道平均每小时玩游戏的次数，我需要知道：
在日期范围内每小时玩的游戏总数
日期范围之间的每小时期间数。
找到第一个是从时间戳中提取小时并按时间进行分组的问题。对于第二种情况，如果日期范围四舍五入到最近的一天，则很容易找到这个值(总计游戏/数字)。
不幸的是我不能假设。我需要帮助的是找到一个时间范围内存在的特定的小时周期的数量。
例句:如果范围是今天下午5点到明天晚上8点，有一个"00“小时(午夜到凌晨1时)，但是2 17，18，19小时(5-6，6-7，7-8)。
谢谢你
浏览 5提问于2014-05-30得票数 0
回答已采纳
1回答
PySpark按多个时间窗口分组
、、、、
大家晚上好。我知道我们可以按df.groupBy('col1,'col2','col3')对多个列进行分组，我认为这种分组意味着它首先按col1分组，对于col1的每个成员，它按col2分组，依此类推。如果这是错误的，请纠正我，我昨天基本上是从PySpark开始的，因为一个大学项目。
我需要按4个成员对数据进行分组:2个字符串列和2个时间窗口。
df.groupBy('col1,'col2','1HourTimeWindow','15MinTimeWindow')
我知道可以使用像这样的df.gro
浏览 15提问于2021-02-17得票数 1
DecimaFormat的语法是如何工作的？我在试着做1234567890 -> 1-234-56789-0。所以我尝试了DecimalFormat("#-###-#####-#);，但这显然是错误的！
浏览 2提问于2014-12-11得票数 0
回答已采纳
1回答
在SQL SERVER中，如何按任何基于时间的间隔进行分组？
为了节省时间，我想出了这个解决方案，对我来说，效果很好。您可以生成任意时间基，然后按任何间隔进行分组。很适合做时间加权平均值。如果有人有更好的方法做这件事，我很乐意听到你的消息。
小时数
declare @startdate datetime2
declare @enddate datetime2
declare @interval int
set @startdate = '2017-01-01 00:00:00'
set @enddate = '2017-01-31 00:00:00'
set
浏览 3提问于2017-01-28得票数 1
回答已采纳
我在一个机器视觉project.In我的项目中工作，我正在使用相机进行打印检查。在我的应用程序中，我使用一个picturebox在屏幕上显示图像，使用两个buttons.In两个按钮，一个用于实时显示，另一个用于fullscreen.With，即在while循环中在picturebox中显示图像。在同一时间，当进程在while循环中时，我必须按全屏按钮。但是我不能按全屏按钮，因为当循环运行时，它不允许我按下表单的任何按钮。(循环是一段时间)为什么会发生这种情况？如何在循环运行时单击此按钮？
浏览 1提问于2011-12-15得票数 2
回答已采纳
1回答
我在一天内有以下时间段：
1) 9:00至13:00
2) 9:30至10:30
3) 9:30到10:30 (这里有意将此间隔设为2x)
4) 11:00至12:00
我可以想象水平时间线上的时隙：
时隙1)
|--------------------------------------------|
9:00 13:00
时隙2)
|-------------|
9:30 10:30
时隙3)
|-------------|
9:30 1
浏览 4提问于2016-12-27得票数 0
2回答
如何按时间聚合日志记录
、、、、
我有一个很大的日志文件，其中包含以时间戳为前缀的日志消息。时间戳的精度为微秒。我想找一个10秒的时间窗口，当最高数量的消息被记录。你怎么能这样做呢？
浏览 3提问于2011-11-03得票数 0
回答已采纳
我得到了一个数据集，里面有许多可观测的状态。我试图应用有限状态马尔可夫链对系统进行建模，但我发现，如果用不同的时间间隔采样观察到的状态，则无法估计过渡概率。我怎么才能找到这些概率？
我会尽量把问题弄得更清楚。我在6个月的时间里随机收集了一些样本.该样本代表系统的“质量”，按离散间隔(0、1、2. 15 )排序从0到15。我需要使用FSMC来模拟系统的行为。到目前为止，我只使用所有样本的频率估计了状态之间的转移概率。我对时间建模不感兴趣，但是，我不确定我是否能够以如此简单的方式估计过渡概率，或者在估计这些概率时，我是否需要考虑样本之间的时间(在我的情况下，这是随机的)。
浏览 0提问于2017-05-04得票数 1
我有一个Chrome扩展，当按下一个按钮时，它会创建一个警报，当警报完成时，这个扩展会创建一个通知。但是，当用户关闭所有窗口时，我希望删除所有的警报。最初，当用户打开其第一个窗口时，我试图清除所有警报：
// background.js
chrome.windows.onCreated.addListener((window) => {
chrome.windows.getAll((windows) => {
if (windows.length == 1) {
chrome.alarms.create('CLEAR_ALL
浏览 14提问于2022-03-17得票数 0
Flink流支持内部连接表达式，如window- join，interval-join.但不支持左联接/完全联接表达式。当然，窗口-cogroup表达式可以实现相同的语义，即使事件立即加入，也必须等待完全窗口大小的时间。我的问题是：
如何从设计角度解释Flink流不支持左连接/完全连接表示？如何通过Flink DataStream API (如果能够立即转发连接事件)来实现它？是否有一种方法可以扩展Flink DataStream API以支持左连接：
.leftJoin()
.where()
.window()
.apply()
浏览 3提问于2021-08-15得票数 0
回答已采纳
我尝试使用Kafka Streams使用不同大小的时间窗口来聚合大量数据。
我将缓存大小增加到2 GB，但当我在1小时内设置窗口大小时，CPU负载达到100%，应用程序开始变慢。
我的代码如下所示：
val tradeStream = builder.stream<String, Trade>(configuration.topicNamePattern, Consumed.with(Serdes.String(), JsonSerde(Trade::class.java)))
tradeStream
.groupBy(
{ _, trade -&
浏览 2提问于2017-12-08得票数 0
1回答
我正在尝试为仪表板上的热图生成数据。我需要按天对数据进行分组，即周一、周二等时，然后按时间间隔对数据进行分组。我可以按天对数据进行分组。但是时间间隔部分不起作用。我正在使用MongoDB。 my Schema示例如下所示 {
"createdAt": "2020-06-30T22:47:32+00:00",
"day": "Wednesday",
"user": {
"$oid": "5ec51d59ddfb380017649591"
浏览 10提问于2020-07-09得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
