LAG (Lakehouse v1)

LAG umożliwia dostęp do wartości kolumny z poprzedniego wiersza w tym samym zbiorze wyników. Zazwyczaj służy do pobrania wartości kolumny z poprzedniego wiersza, według wskazanego uporządkowania.

Zobacz też: LEAD

Składnia Analyze

func.lag(<expr>, <offset>).over(partition_by=[<columns>], order_by=[<columns>])

Przykłady Analyze

table.product_name, table.sale_amount, func.lag(table.sale_amount, 1).over(partition_by=table.product_name, order_by=table.sale_id).alias('previous_sale_amount')

product_name | sale_amount | previous_sale_amount
-----------------------------------------------
Product A    | 1000.00     | NULL
Product A    | 1500.00     | 1000.00
Product A    | 2000.00     | 1500.00
Product B    | 500.00      | NULL
Product B    | 800.00      | 500.00
Product B    | 1200.00     | 800.00

Składnia SQL

LAG(expression [, offset [, default]]) OVER (PARTITION BY partition_expression ORDER BY sort_expression)

• offset: określa liczbę wierszy przed bieżącym wierszem (LEAD) lub za nim (LAG) w obrębie partycji, z których ma zostać pobrana wartość. Domyślnie 1.

Uwaga: ustawienie ujemnego przesunięcia daje taki sam efekt jak użycie funkcji LEAD.

• default: określa wartość zwracaną, gdy funkcja LEAD lub LAG napotka sytuację, w której nie ma dostępnej wartości, ponieważ przesunięcie wykracza poza granice partycji. Domyślnie NULL.

Przykłady SQL

CREATE TABLE sales (
  sale_id INT,
  product_name VARCHAR(50),
  sale_amount DECIMAL(10, 2)
);

INSERT INTO sales (sale_id, product_name, sale_amount)
VALUES (1, 'Product A', 1000.00),
       (2, 'Product A', 1500.00),
       (3, 'Product A', 2000.00),
       (4, 'Product B', 500.00),
       (5, 'Product B', 800.00),
       (6, 'Product B', 1200.00);

SELECT product_name, sale_amount, LAG(sale_amount) OVER (PARTITION BY product_name ORDER BY sale_id) AS previous_sale_amount
FROM sales;

product_name | sale_amount | previous_sale_amount
-----------------------------------------------
Product A    | 1000.00     | NULL
Product A    | 1500.00     | 1000.00
Product A    | 2000.00     | 1500.00
Product B    | 500.00      | NULL
Product B    | 800.00      | 500.00
Product B    | 1200.00     | 800.00

-- The following statements return the same result.
SELECT product_name, sale_amount, LAG(sale_amount, -1) OVER (PARTITION BY product_name ORDER BY sale_id) AS next_sale_amount
FROM sales;

SELECT product_name, sale_amount, LEAD(sale_amount) OVER (PARTITION BY product_name ORDER BY sale_id) AS next_sale_amount
FROM sales;

product_name|sale_amount|next_sale_amount|
------------+-----------+----------------+
Product A   |    1000.00|         1500.00|
Product A   |    1500.00|         2000.00|
Product A   |    2000.00|                |
Product B   |     500.00|          800.00|
Product B   |     800.00|         1200.00|
Product B   |    1200.00|                |