标签: window-functions

是否可以引用窗口分区中的当前行？我想做如下的事情：

SELECT min(ABS(variable - CURRENT.variable)) over (order by criterion RANGE UNBOUNDED PRECEDING)

也就是说，我想在给定的分区中找到最接近当前值的变量。可以做这样的事情吗？

举个例子，来自：

criterion | variable 1 2 2 4 3 2 4 7 5 6

我们将得到：

null 2 0 3 1

谢谢

我有一个具有三列 time、col1、col2 的流数据帧。我必须在第 2 列上应用滞后函数。我尝试过以下查询。

val w = org.apache.spark.sql.expressions.Window.oderBy("time")
df.select(col("time"),col("col1"),lag("col3",1).over(w))

但它给出了以下异常

org.apache.spark.sql.AnalysisException: Non-time-based windows are not supported on streaming DataFrames/Datasets

我怎样才能做到这一点？

提前致谢。

我正在尝试利用 MAX() OVER PARTITION BY 函数来评估我公司购买的特定部件的最新收据。下面是去年一些零件的信息示例表：

| VEND_NUM | VEND_NAME    | RECEIPT_NUM | RECEIPT_ITEM | RECEIPT_DATE |
|----------|--------------|-------------|----------|--------------|
| 100      | SmallTech    | 2001        | 5844HAJ  | 11/22/2017   |
| 100      | SmallTech    | 3188        | 5521LRO  | 12/31/2017   |
| 200      | RealSolution | 5109        | 8715JUI  | 05/01/2017   |
| 100      | SmallTech    | 3232        | 8715JUI  | 11/01/2017   |
| 200      | RealSolution | 2101        | 4715TEN  | 01/01/2017   |

如您所见，第三行和第四行显示同一部件号的两个不同供应商。

这是我当前的查询：

WITH

-- various other subqueries …

我正在寻找按日期时间值在分区上运行窗口函数的最佳方法。但是，我不想按确切时间分区，而是希望按日期时间分区，例如彼此相差 15 分钟以内的日期时间。

这是我桌子上的一小部分。

CREATE TABLE my_table(ID VARCHAR(5), in_time DATETIME)

INSERT INTO my_table (ID, in_time) VALUES
('4844', '2017-04-06 10:15:00.000'),
('5221', '2017-11-24 11:18:00.000'),
('5221', '2017-11-24 11:18:00.000'),
('5221', '2017-11-25 14:23:00.000'),
('8486', '2017-10-10 15:30:00.000'),
('8486', '2017-10-10 15:32:00.000'),
('8486', '2017-10-10 15:46:00.000'), -- new row after updating question
('8486', '2017-10-10 16:00:00.000') -- new row after updating question

这是我现在使用的查询：

SELECT *, 
    ROW_NUMBER() OVER(PARTITION BY ID, in_time ORDER BY ID, in_time) AS filter_row
FROM my_table

正如预期的那样，这给了我这个：

ID      in_time                     filter_row
4844    2017-04-06 10:15:00.000     1
5221    2017-11-24 11:18:00.000     1 …

我有下表。

First_Value满足条件时可以创建窗口函数吗？

例如，当 is = 1 时我需要第一个值并按 id 分区

表A

ID    Date       IS
 1     1/1/18    0
 1     1/2/18    1

我的工作：

   SELECT 
   CASE
   WHEN A.IS = 1 THEN A.DATE END)OVER (PARTITION BY A.ID ORDER BY A.DATE)                
   END FIRST_ATTEMPT_DT
   FROM TABLEA A

我想计算 Snowflake 中各行的累积乘积。

基本上我的月费是随着时间的推移而倍增的。

（有些数据库有product()相应的 SQL 函数）。

给定一个像这样的表：

另请参阅DB Fiddle 示例。

如何识别连续几天的连续但允许最大差距？

数据中的原始列是person_id和contact_day …

我正在尝试使用按日期排序的组中的NULL先前值填充多个列（不同列类型 INT、VARCHAR）中的值。NOT NULL考虑下表：

CREATE TABLE IF NOT EXISTS test (
   id VARCHAR,
   date DATE,
   value_1 INT,
   value_2 VARCHAR
);


INSERT INTO test VALUES 
(1, '2022-01-04', 5, 'asdf'),
(1, '2022-01-03', NULL, NULL),
(1, '2022-01-02', NULL, 'def'),
(1, '2022-01-01', 4, NULL),
(2, '2022-01-04', 1, 'a'),
(2, '2022-01-03', NULL, NULL),
(2, '2022-01-02', 2, 'b'),
(2, '2022-01-01', NULL, NULL);

我想到达这里（请考虑 value_1 --> INTEGER、value_2 字符串）：