我需要在一些稀疏的datetime索引的DataFrame上的滚动窗口上应用一个函数(行之间的时间间隔是可变的)。='10min').apply(value_diff)
我需要结果的第一个值是基于至少10分钟的数据。不幸的是，rolling()函数的min_periods参数不接受偏移量，只接受点数，我不能为它指定一个固定值，因为一个窗口中<e
浏览 11提问于2020-05-09得票数 0
我想做的就是这样：
计算剩余的3块数据的平均值。如何通过pandas.DataFrame.rolling().apply()或pandas.DataSeries.rolling().apply()完成此操作
浏览 5提问于2016-12-30得票数 0
3回答
我试图使用pandas.DataFrame.rolling实现以下目标：
在索引i，我要滚动的sum，mean，median，.对于最后一个使用size_win窗口的parzen值。重要的是只考虑过去的值(即索引<i)，而不考虑来自未来的任何值(这是一个“我们在时间上有什么信息i?”情况)。第二个约束是:我想要一个单边的parzen窗口，即索引i的值应该得到
浏览 6提问于2017-09-24得票数 2
1回答
我有一个日志数据库，有几个查找表和一个有7900万行的大型事件表。在繁忙的日子里，我的代码会插入超过300万行，所以如果不是因为每半个小时我就会将最新的数据复制到一个单独服务器上的存档数据库中，那么事件表就会是巨大的，然后每晚从生产中删除所有有超过一个月历史的行。我不认为它们会造成任何阻塞，只要我在每个delete语句之间添加100 ms的延迟(下面的脚本)，但我觉得事情还可以改进。日志数据库是否应该处于快照隔离模式？
浏览 0提问于2014-04-23得票数 1
回答已采纳
1回答
我想知道是否有人知道如何在熊猫数据帧上实现滚动/移动窗口PCA。我环顾四周，发现了在R和MATLAB中的实现，但没有Python。任何帮助都将不胜感激！这不是重复窗口-移动窗口PCA与整个数据帧上的PCA不同。如果您不了解其中的区别，请参阅pandas.DataFrame.rolling()
浏览 23提问于2017-08-29得票数 3
1回答
从上个星期开始，我用scala中的Flink构建了一个DataStream程序。但我的行为很奇怪，弗林克比我想象的要多。我的processFunction中有一个4 processFunction的元组( INT，long)，我用它在不同的时间范围内得到不同的唯一计数器，并且我预计大部分内存都被这个列表使用了。所以我打印了JVM的他的生活。我很惊讶这么多的记忆被使用</em
浏览 1提问于2018-02-12得票数 1
2回答
我正试图为不规则的时间序列数据集提取有趣的统计数据，但找不到适合这项工作的工具。操作定期采样的时间序列或任何时间的基于索引的序列的工具是很容易找到的，尽管我在试图解决的问题上没有多少运气。理想情况下，我希望使用一个不需要t的函数，因为这将需要对该函数进行length(vecZ)调用，这忽略了可以更有效地计算<e
浏览 2提问于2012-05-05得票数 15
1回答
我是新的Flink流API，我想完成以下简单(IMO)任务。我有两个流，我想加入他们使用计数的窗口。到目前为止，我掌握的代码如下：
private static final String recordFile = "some_file.txt实际上，对apply方法的调用从未被调用过(通过在调试模式上添加断点来验证)。我认为，前面的主要原因是我的数据没有
浏览 1提问于2016-06-09得票数 2
回答已采纳
4回答
我想计算2x2矩阵的行列式，它是通过在Nx2矩阵上滚动一个大小为2的窗口而得到的。我只是用行列式作为一个例子函数。一般来说，我想将一个函数应用到一个数据文件中，它是通过窗口化一个更大的数据帧来实现的。pd "X": [1,2], })现在，我可
浏览 0提问于2017-05-15得票数 7
回答已采纳
我目前使用的是Java servlet，它具有siddhi核心、api和查询jar库。我使用SiddhiManager类来创建流、查询和回调。servlet允许我运行常规查询，但不会查询基于时间窗口的查询，例如-每次调用servlet时，时间窗口都会重新启动，导致<em
浏览 1提问于2015-07-27得票数 0
我希望每隔M分钟处理最后N小时的数据。数据通过pubsub有各种延迟，但我不想因为时间偏差或数据延迟而延迟窗口触发。也就是说，我只想处理触发时可用的数据，并希望基于墙时间触发(但每个窗口应包含基于数据事件时间的[触发时间-M小时，触发时间)之间的数据。)我正在尝试使用SlidingWindows，但触发是基于事
浏览 1提问于2016-11-08得票数 2
在Flink中，我有一个带有键控事件流的Job (例如:每个键平均每天有10个事件)。它们被处理为基于事件时间的滑动窗口(例如:90天窗口大小和1天窗口滑动)。事件是从Kafka消费的，Kafka会持久化所有的事件历史(例如:最近3年)。 有时我想重新启动Flink:用于维护、bug处理等，或者使用已经包含事件历史的Kafka启动一个新的Flink实例。在这种情况下，我想跳过所有触发，除了每个键<e
浏览 9提问于2019-06-05得票数 0
回答已采纳
我正在为我的流要求之一在会话窗口上执行POC操作。为此，我使用会话窗口，因为这符合要求，在这里，我必须将具有唯一事务id的事件聚合到列表中。1)首先，我使用了一些事务id X的数据，其事件日期范围为当它们进入同一个会话时，它们都被聚集在一起。2)接着，我摄入了单一记录事务id X time START Mon 4月16日22:26:45美国东部时间</
浏览 0提问于2018-04-17得票数 2
回答已采纳
1回答
有人能解释一下TTL实际上是如何工作的对于TWCS，我看到这样的过程：它创造了一个用SSTableN写的墓碑女巫？但是，如果SSTable1和SSTable1和SSTableN由于来自不同的时间窗口而无法压缩，那么如何才能丢
浏览 0提问于2023-05-26得票数 0
回答已采纳
对我们来说，成本是基于存储的数据量。
我们希望能够根据记录的更新时间来查询记录。目前，当我们添加或更新一条记录时，我们将一个bin设置为当前的纪元时间，并可以在该bin上运行扫描查询。我刚刚想到，Aerospike知道何时使记录失效，因为我们可以通过从记录元数据中查询TTL值，因此可以推断具有TTL值的记录的上升时间。我们有效地使用空间来存储已知的值。是否可以<e
浏览 2提问于2016-01-29得票数 3
给定向量大小n和窗口大小k，如何有效地计算n个log k时间内的滑动窗口最小值？例如，对于向量1 4 3 2 2 5 4 2和窗口大小2，输出为1 3 2 2 2 4 2.显然，我可以使用分区和映射来完成它，但那是n*k时间。
我认为我需要跟踪排序地图中的最小值，并在窗口外更新地图。但是，尽管我可以在日志时间内获得排序映射的最小值，但在地图中搜索任何过期的索引并不
浏览 7提问于2017-01-07得票数 1
回答已采纳
1回答
这可以通过让人们选择化名来实现，或者直接隐藏每个人。主持人还需要看谁是有联系的只允许我允许进入的人。这可以通过一次密码、电子邮件注册或其他方式来完成。阻止人们在规定的日期/时间之前加入或在会议结束后逗留不需要安装软件，所以我想基于web的方法是可行的</
浏览 0提问于2021-01-18得票数 1
我们正在与Azure IoT集线器合作，它将数据发送到Azure，并且我们正在使用TSI从它获取数据。格式的数据-{"status":0, "timestamp":123456, plc_id:1}{"status":1, "timestamp":123456, plc_id:1}
{"s
浏览 1提问于2021-12-01得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
