【入門編】ウィンドウ関数 – Cloud Spanner

こんにちは。Cloud Spannerの世界へようこそ。

世界中の膨大なデータを一瞬でさばき、かつ決して止まらない。そんな「魔法」のようなデータベースであるCloud Spannerですが、その真価は単なるデータの保存場所ではなく、「データから知恵を絞り出す分析力」にあります。

今回は、その分析力の要となる「ウィンドウ関数」についてお話ししましょう。難しい言葉は使いません。一緒に紐解いていきましょう。

—

ウィンドウ関数って、結局なに？

データベースの世界で「ウィンドウ関数」と聞くと、身構えてしまうかもしれません。でも、イメージしてみてください。

あなたは巨大な図書館の司書さんです。目の前には数万冊の記録カードがバラバラに置かれています。
「この棚の中で、貸出回数が多い順にランキングを付けたい」
「前の人が借りた本と、今の人が借りた本を比較したい」

こういった作業をするとき、あなたはカードを一枚ずつ見るのではなく、「特定の範囲（棚）」に注目して、その中での順序や関係性を見渡しますよね？

この「範囲を見渡す窓（ウィンドウ）」を作って計算するのが、ウィンドウ関数です。

—

主な登場人物たち（よく使う関数）

Cloud Spannerは、分析を快適にするための強力な武器を標準で備えています。

1. `ROW_NUMBER()` ：「はい、1番目、2番目…」と単純に番号を振る、出席番号係です。
2. `RANK()` ：「同率2位が2人いたら、次は4位！」という、スポーツ大会の順位付けが得意な担当者です。
3. `LEAD()` / `LAG()` ：「前のデータはなんだった？」「次のデータは？」と、隣の列を覗き込むスパイのような関数です。

—

実践：カフェの注文履歴で考えてみよう

例えば、あるカフェの注文履歴テーブルがあるとします。
「お客さんごとに、注文時刻の順番に番号を振る」という処理をしてみましょう。

SELECT
customer_id,
order_time,
— customer_idごとにグループ化し、order_time順で番号を振る
ROW_NUMBER() OVER(PARTITION BY customer_id ORDER BY order_time) AS order_seq
FROM Orders;

`PARTITION BY`: 「お客さんごと」に棚を分ける指示です。
`ORDER BY`: 棚の中を「注文時刻」で並べる指示です。

これで、「あ、この人は今日で3回目の注文だな」ということが一瞬で分かります。

—

なぜCloud Spannerでこれを使うのか？

普通のデータベースでもウィンドウ関数は使えます。しかし、Cloud Spannerでこれを使うことには、「極限の知見」とも言える理由があります。

それは、「数億行のデータでも、リアルタイムに集計できる」という点です。

一般的なデータベースでは、データが増えれば増えるほど、こうした集計は「重い処理」になりがちです。しかし、Cloud Spannerはデータを世界中に分散して持っています。ウィンドウ関数を使う際も、その分散された力を最大限に活かし、裏側で驚くべき並列処理を行ってくれるのです。

つまり、あなたは「データがどれだけ増えても、同じ感覚で分析クエリを投げ続けられる」という特権を手に入れるわけです。

—

複雑な分析への活用テクニック

実務では、単なるランキングよりも少し複雑なことが求められます。

例えば、「前回の注文から、今回の注文まで何分空いたか？」を知りたい場合。

SELECT
customer_id,
order_time,
— 前の注文時刻を引っ張ってくる（LAG）
LAG(order_time) OVER(PARTITION BY customer_id ORDER BY order_time) AS prev_order_time,
— 今の時刻との差分を計算
TIMESTAMP_DIFF(order_time, LAG(order_time) OVER(PARTITION BY customer_id ORDER BY order_time), MINUTE) AS gap_minutes
FROM Orders;

このように `LAG()` を使うだけで、いちいち別のテーブルと結合（JOIN）したり、複雑なプログラムを書いたりする必要はありません。クエリひとつで「顧客の行動パターン」が浮き彫りになるのです。

—

最後に：ここをクリアすれば大丈夫

最初は `OVER(…)` の中に書く `PARTITION BY` や `ORDER BY` の組み合わせに戸惑うかもしれません。でも、大丈夫。

「どの単位で（PARTITION）、どう並べて（ORDER）、何を見たいのか（関数）」

この3つを頭の中で整理する癖をつければ、もうあなたはCloud Spannerの分析マスターへの階段を登り始めています。

最初は小さなデータで試してみてください。そして、データが100万行、1000万行と増えても、そのクエリが全く変わらない速度で返ってくる感動をぜひ体験してほしいのです。

さあ、次はどんなデータを「窓」から覗いてみますか？応援していますよ。