我正在编写一些SQL查询，以便根据历史服务数据为客户流失预测创建一个数据集。其中一些服务可以追溯到几年前。他们中的一小部分人在过去的某个时候被搅动了，而另一些人最终得到了更新。其中一些属性基于每个服务处于活动状态时处于活动状态的服务的聚合。例如，我想要找出当单个帐户处于活动状态时，同一帐户下有多少个服务处于活动状态。我目前正在使用Python wrapper<em
浏览 33提问于2021-08-17得票数 0
回答已采纳
1回答
我想编写一个Spark管道来对我的生产DB数据执行聚合，然后将数据写回DB。我编写管道的目的是执行聚合，而不是在运行时影响生产DB，这意味着我不希望用户在进行聚合时遇到滞后，也不希望DB有严重的IOPS。例如，作为SQL运行的等效聚合查询将花费很长时间，也会耗尽RDS IOPS，这会导致用户无法获取数据--试图
浏览 5提问于2022-09-12得票数 0
我们使用带有时间窗口的kafka-stream聚合来计算事件的结束和。我们已经实现了我们的需求，但是我们有一个中间聚合结果的问题。聚合计算输入的记录值之和(按键分组)，并返回KTable<String, Integer>。
而不缓存：对键A发出一系列输出记录，表示结果聚合表中的更改。我们的问题是，我们有其他的
浏览 0提问于2018-07-12得票数 1
我想使用星火SQL窗口函数来进行一些聚合和窗口化。
我想运行这个查询，给出每个类别的最大2收入，同时也给出每个类别的产品计数。在我运行这个查询之后 product, revenue SELECT category,
revenuePARTITION BY cate
浏览 0提问于2020-05-19得票数 2
回答已采纳
1回答
TL;DR:长时间运行的查询会杀死其他用户的整个应用程序。规避这种情况的策略是什么？
您好，我在AWST2上运行MongoDB。小实例(2 2GB，1核)适用于流量较小的Meteor应用程序。它工作得很好，除非人们想要运行一个执行大约30个聚合以显示各种KPI的报告。当一个用户运行报告(大约需要一分钟才能完成)时，应用程序的性能非常糟糕(几乎为零
浏览 17提问于2018-01-07得票数 2
1回答
我试图编写一个聚合查询，以过滤两个子文档并对它们进行分组，但我似乎无法弄清楚如何使用单个查询来实现它，它是否可行。我尝试过一些聚合和mapReduce查询，但无法使它们工作。"id" : 'A', }]]
基本上，我想分组读取和保存的子文档分别跨用户
浏览 1提问于2015-03-03得票数 0
回答已采纳
1回答
我有一个带有文本消息和每行时间戳值的Dataframe。我可以通过遍历整个Dataframe，添加时间戳差异，并在实现时间窗口时插入新的Dataframe来实现这一点。它可以工作，但很难看，我正在寻找一些关于如何在Scala中以更实用、更优雅的方式完成这一任务的建议。我查看了窗口函数，但是由于我没有进行聚合，所以在创建WindowSpec之后，我
浏览 0提问于2019-08-04得票数 2
回答已采纳
1回答
我有一个web应用程序，它有大量的表和变量，用户可以在运行时选择(或不选择)。如下所示：Table ATable CResult Display = A.field1, A.Field3, B.field19
可以在单个结果集中返回的15+表中最多有100+个总字段。我们有一个查询，当前的工作方式是创建一个临时表来<
浏览 1提问于2014-11-25得票数 0
基本上，它说尽量避免Mongo的MR查询，因为它是单线程的，根本不应该是实时的。两年过去了，我想知道从那以后发生了什么变化。现在我们有了MongoDb 2.2。我听说MRs现在是多线程的。请分享你的想法在MR使用的实时请求，如获取数据的web应用程序频繁的http请求。它能有效地使用索引吗？
浏览 1提问于2012-10-02得票数 29
回答已采纳
1回答
我已经针对这个表编写了一个查询，该查询查找不匹配的行，该查询每行返回三个键值。每列都是一个键值，表示参与不匹配的服务器。当第三列与第一列不同时，它是不匹配的，我想详细查看所有这些行。为了进行检查，我希望使用查询的结果来获得代码所表示的每条完整记录的详细信息，该查询</
浏览 0提问于2016-02-04得票数 0
1回答
Toad变量
、、
我最近开始在蟾蜍DB2中工作，我正在尝试设计一些模板，在这些模板中，我使用了一个特定的术语来处理多个查询。困难在于，我很少将所有查询作为一个批处理来运行。我运行一个查询来研究如何最好地编写代码来进行BA修改；研究结果，并记下需要更改的术语和唯一标识记录的术语。所以我临时运行它们，我不想将它们作为一个批处理或单个
浏览 0提问于2017-07-21得票数 0
在Server中，我正在编写一个查询，以计算某些用户事件之间的一些时间，为此，我需要为某个事件运行一个设置日期的聚合查询。一个事件可以在多天内运行，对于我用来验证我的查询的数据，有2月27日，2月28日的数据，但是该事件从2月25日到3月1日。我只使用一个子集的数据来验证查询，将会有更多<em
浏览 0提问于2018-03-22得票数 0
回答已采纳
我们面临的问题，与BigQuery的范围装饰在流表。范围修饰器查询提供重复数据。我的BQ表是通过流插入定期从客户事件中获取数据。另一个任务是使用范围修饰器定期从表中获取时间约束数据，并将其发送到数据流作业。喜欢SELECT * FROM [project_id:alpha.user_action@1450287482158]
当我运行这个查询时，得到了91条记录。15分钟后，基于最后一次间隔的</e
浏览 8提问于2015-12-17得票数 1
回答已采纳
1回答
对于KStreams聚合和窗口，我有一个问题。我想把一个记录聚合到一个记录列表中，只要它在一个时间窗口内，它就具有相同的键。我之所以选择SessionWindows，是因为我必须使用会话中的移动窗口:假设记录A在10 :00到达；那么在10秒窗口时间内(直到10:00:10)内到达的所有其他记录都将落入同一会话，同时要记住，这导致我们有一个移动窗口+10从最后收到
浏览 0提问于2019-05-29得票数 3
我是apache的新手，并试图了解EventTime和窗口的概念是如何由flink处理的。下面是我的设想：，然后我使用下面的代码来打开上面的窗口并尝试获取聚合：
.window(TumblingEventTime
浏览 1提问于2021-12-16得票数 0
1回答
我很难弄清楚如何处理resolvejs中聚合根之间的关系的一些基本问题。基本的问题是我如何处理关系的完整性？要做到这一点，似乎你需要同时了解这两方面的知识，但这在编写端似乎是不允许的。设置如下:我正在尝试构建一个用户管理工具，并且我有两个聚合根，User和Organisation。我需要允许两者相互独立地存在，并定义它们之间的access关系(即用户可以访问任何数
浏览 21提问于2021-06-26得票数 2
4回答
同步来自多个数据源的数据
、、、、
我们的团队正在尝试构建一个预测维护系统，其任务是查看一组事件，并预测这些事件是否描述了一组已知的异常。根据特征集的不同，推理引擎将订阅多个Kafka主题和来自这些主题的流数据，以持续输出推理。
为了将一组事件分类为异常，必须在同一时间窗口中发生事件。例如，有三个数据源将各自的事件推入Kafka主题，但由于某种原因，数据不同步。因此，其中
浏览 0提问于2019-05-27得票数 8
回答已采纳
1回答
我读过mongodb切分指南，但我不确定哪种类型的切分键适合我的应用程序。欢迎任何建议。但我在海量数据上广泛使用了聚合框架。所有的聚合都有一个时限-即大多是最近的一
浏览 4提问于2014-02-25得票数 1
让我们考虑一个主题，其中包含多个分区和按事件时间顺序编写的消息，而没有任何特定的分区方案。Kafka Streams应用程序对这些消息进行一些转换，然后按某个键分组，然后使用给定的宽限期通过事件时窗口聚合消息。这意味着，在groupBy洗牌之后，当消息来自不同的任务时，在内部主题的同一分区中的消息之间的事件时间排序将不会被保留。过一段时间
浏览 3提问于2020-11-16得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
