window-functions相关内容

Spark 窗口函数 - rangeBetween 日期

我有一个包含数据的 Spark SQL DataFrame，我想要获取的是给定日期范围内当前行之前的所有行.因此，例如，我希望在给定行之前拥有 7 天前的所有行.我发现我需要使用 Window Function 像: Window \.partitionBy('id') \.orderBy('开始') 问题来了.我想要一个 rangeBetween 7 天，但我在 Spark 文档中找不到任何 ..

发布时间：2021-11-12 05:25:51 sql apache-spark pyspark apache-spark-sql window-functions 其他开发

Kafka Stream 抑制会话窗口聚合

我在 Kafka 流应用程序中编写了此代码: KGroupedStreamgroupedStream = stream.groupByKey();groupedStream.windowedBy(SessionWindows.with(Duration.ofSeconds(3)).grace(Duration.ofSeconds(3))).aggregate(() -> {...}).suppr ..

发布时间：2021-11-12 03:33:08 apache-kafka apache-kafka-streams window-functions suppress 其他开发

Kafka Stream 抑制会话窗口聚合

我在 Kafka 流应用程序中编写了此代码: KGroupedStreamgroupedStream = stream.groupByKey();groupedStream.windowedBy(SessionWindows.with(Duration.ofSeconds(3)).grace(Duration.ofSeconds(3))).aggregate(() -> {...}).suppr ..

发布时间：2021-11-12 01:41:50 apache-kafka apache-kafka-streams window-functions suppress 其他开发

Postgres Wide To Long 按大小写/值

我有一张像: id 分组值1 组 1 是2 组 1 是2 组 2 是3 组 1 是 我已经管理了 id 组 1 组 21 年2 年2 年3 岁 我需要转置 id 组 1 组 21 是 否2 年3 是 否 解决方案 试试这个. SELECT id,MAX(案例分组时 = '组 1'然后'Y'其他'N'完)作为“第 1 组",MAX(案例分组时 = '第 2 组'然后'Y'其他'N'完 ..

发布时间：2021-09-25 19:38:46 postgresql window-functions 其他开发

以行比较为条件的 Postgres 聚合总和

所以，我有看起来像这样的数据 User_Object |文件大小 |创建日期 |删除日期第 1 行 |40 |5 月 10 日 |8月20日第 2 行 |10 |6 月 3 日 |空值第 3 行 |20 |11 月 8 日 |空值 我正在构建统计数据，以根据基于时间的数据点将用户数据使用情况记录到图表中.但是，我很难开发一个查询来获取它之前所有查询的每一行的总和，但仅适用于创建该行时存在的行. ..

发布时间：2021-09-25 19:38:43 postgresql window-functions 其他开发

MYSQL - 警告:#1287 在表达式中设置用户变量已被弃用，并将在未来版本中删除

警告:#1287 在表达式中设置用户变量已被弃用，并将在未来版本中删除.考虑替代方案:“SET variable=expression, ..."或“SELECT expression(s) INTO variables(s)". 这是 MySQL 8.0.21 吐出来的.代码有效......但我也需要它在未来版本中工作......所以我的问题是这个警告的正确方法是什么? 我需要将一个 ..

发布时间：2021-09-25 19:38:40 mysql window-functions row-number 数据库

计算 PostgreSQL 中的累积日总和

我的数据是这样的 id,submission_state,outcome_state,company_id,office_id,date_created,location_city,location_state,location_country,work_type,is_foreignop_01CB7TX0DS8AQYKWNZ0AQ80CAY,WILL_SUBMIT,UNKNOWN,co_01C ..

发布时间：2021-09-25 19:38:37 sql postgresql window-functions 其他开发

ERROR 1064 (42000) 过度分区语法中的数据库错误

mysql>从 FinalTable 中选择 *；+------+-------+-------+--------------+|身份证 |姓名 |状态 |时间戳 |+------+-------+-------+--------------+|12 |姓名1 |德克萨斯 |2020-01-25 11:29:36 ||14 |姓名3 |CA |2020-01-25 11:29:36 ||14 |姓 ..

发布时间：2021-09-25 19:38:34 mysql sql window-functions mysql-5.7 数据库

使用array_agg和struct后如何在列中查找值?

在我的数据库中使用以下代码后，得到以下结果: 选择用户ID，array_agg(struct(ORDER_TIME, DELIVERY_TIME, PLATFORM) order by ORDER_TIME) STATS来自`project.dataset.table`按 USERID 分组有计数(1)>1按 USERID 排序 用户 IDSTATS.ORDER_TIMESTATS.DELIV ..

发布时间：2021-09-25 19:38:31 sql google-bigquery aggregate-functions window-functions 其他开发

MySQL窗口函数每5分钟计算一次平均值或最大值

我有一个表 data，其中包含 clock (unixtime) 和 value 列，其中记录每 50-70 秒出现一次.我需要绘制反映每 5 分钟时间的最大值(或平均值)的月度图表.为此，我需要进行一个查询，每 5 分钟对值进行一次分组和计数.但我就是做不到. SELECT clock, value FROM data WHERE clock BETWEEN 1622667600 AND 16 ..

发布时间：2021-09-25 19:38:28 mysql sql group-by window-functions 数据库

我可以在窗口函数的帮助下计算总和吗?

我可以通过查询找到总数: with sub_total as (选择*,sum(qty*price) OVER(PARTITION BY invoice_id, group_id ) AS order_cost从发票)- 这里我如何得到预期的结果:选择 *，(SELECT sum(x) from (SELECT sum( DISTINCT order_cost ) AS x FROM sub_t ..

发布时间：2021-09-25 19:38:25 postgresql window-functions 其他开发

PostgreSQL, Window 函数使用问题(附具体例子)

我在 PostgreSQL 中遇到了困难.我正在使用的模式/模型不受我的控制，也不是我能够改变的，所以我试图找出处理我所发牌的最佳方法. 首先，针对此问题简化了架构，但本质上是发票(类型 = T)和交易(类型 T)行合并到同一个表中.每个发票可以并且将会有 n 个交易行和每个客户的 n 个发票可以混合，如下所示. 鉴于此架构: 创建表 t (id 序列主键，类型 VARCHAR (5 ..

发布时间：2021-09-25 19:38:22 sql postgresql window-functions 其他开发

将连续的非零行标记为不同的分区?

假设我们有这个简单的架构和数据: DROP TABLE #builds创建表#builds (Id INT IDENTITY(1,1) 非空，开始时间 INT，已通过 BIT)INSERT INTO #builds (StartTime, IsPassed) VALUES(1, 1),(7, 1),(10, 0),(15, 1),(21, 1),(26, 0),(34, 0),(44, 0),( ..

发布时间：2021-09-25 19:38:19 sql sql-server window-functions 数据库

移动中位数，T-SQL 中的模式

我使用的是 SQL Server 2012，我知道计算移动平均线非常简单.但我需要的是获取像这样定义的窗口框架的模式和中位数(当前行之前的窗口为 2；月份唯一): MONTH |代码 |中位数 |模式1 0 0 02 3 1.5 03 2 2 04 2 2 25 2 2 26 5 2 27 3 3 2 如果有多个值符合模式，则选择第一个. 解决方案 我彻底评论了我的代码.阅读我对我的模 ..

发布时间：2021-09-25 19:38:16 sql-server tsql window-functions 数据库

分区总和不起作用

我有一些关于分区函数的代码，但它不起作用. 我收到一条错误消息，内容为 'Sales' 附近的语法不正确 有人知道为什么吗?看了其他分区问题，没找到答案， 代码(下面)应该从 Aggregated Sales History 表中选择 PriceZoneID 和 Sales，然后使用 OVER 函数总结总销售额，并将该数据放入名为 Total Sales 的新列中. ..

发布时间：2021-09-25 19:38:13 sql sql-server window-functions 数据库

在 MariaDB 中使用 ROW_NUMBER() 函数的问题

我想在选择表输出中有一个行号列，但是当我尝试使用 ROW_NUMBER() 函数时，MariaDB 会引发语法错误.网上有几个参考资料(http://www.mysqltutorial.org/mysql-window-functions/mysql-row_number-function/ )但到目前为止我还没有成功.这是我的 MariaDB 表的一部分: +----------------- ..

发布时间：2021-09-25 19:38:11 mariadb window-functions 其他开发

用 postgresql 中分区的最后一个值填充列

我正在尝试返回分区的最后一个值并将其应用于列的其余部分 例如，如果我有以下... ID 日期状态1 201501011 201502011 201503011 20150401 作废2 201501012 201502012 20150301 我想退货. ID 日期状态1 20150101 作废1 20150201 作废1 20150301 作废1 20150401 作废2 20150 ..

发布时间：2021-09-25 19:38:08 sql postgresql window-functions 其他开发

SQL - 如果满足使用多个先前列的条件，则 LAG 以获取先前值

我有一个由以下人员创建的表: 创建表#test_table(身份证号码,EventName VARCHAR(50),HomeTeam VARCHAR(25),公制INT)插入 #test_table 值(1, 'Team A vs Team B', 'Team A', 5),(2, 'Team A vs Team B', 'Team A', 7),(3, 'Team C vs Team D', ..

发布时间：2021-09-25 19:38:05 sql sql-server window-functions 数据库

ROW_NUMBER 查询

我有一张桌子: 行程停止时间-----------------1 1:101 乙 1:161 乙 1:201 乙 1:251 C 1:311 乙 1:402 一 2:102 乙 2:172 C 2:202 乙 2:25 我想在查询输出中再添加一列: 行程停止时序-------------------------1 1:10 11 乙 1:16 21 乙 1:20 21 乙 1:25 21 C ..

发布时间：2021-09-25 19:38:02 sql oracle window-functions 数据库

具有每月偏移量的熊猫滚动()函数

我正在尝试在带有月度数据的 Pandas 数据框上使用滚动 () 函数.但是，我删除了一些 NaN 值，所以现在我的时间序列中有一些差距.因此，基本窗口参数给出了一个误导性的答案，因为它只是查看了之前的观察结果: 将pandas导入为pd将 numpy 导入为 np随机导入dft = pd.DataFrame(np.random.randint(0,10,size=len(dt)),index= ..

发布时间：2021-09-25 19:37:59 python pandas window-functions rolling-computation Python