Pencere fonksiyonunda veriyi bölümlendirme

Snowflake'ta Pencere Fonksiyonları

Jake Roach

Field Data Engineer

Veri sıralama

Burada, sonuç kümesindeki tüm kayıtları sıralıyoruz!

      user_id  |    event_name   |  km_traveled  |  closest_attendees 
      -------  | --------------- | ------------- | ----------------- 
      user_81  |  Lunar Drift    |      0.5      |         1         
      user_02  |  Lunar Drift    |      1.1      |         2       
      user_33  |  Crimson Arc    |      8.6      |         3          
      user_33  |  Neon Prophet   |      8.6      |         3         
      user_15  |  VibeStorm      |      17       |         5          
      user_94  |  The Dusk Owls  |      41       |         6        
      user_47  |  Lunar Drift    |      61       |         7   
      user_56  |  Crimson Arc    |      116      |         8

Bölümlerle veri sıralama

Şimdi, her pencere için veriyi sıralamak istiyoruz.

Her mekâna yolculuk mesafesine göre konser katılımcılarını sıralayan bir tablo

PARTITION BY

SELECT
    user_id,
    event_name,
    distance_traveled,

    RANK() OVER(
        -- Pencereyi event_name ile oluşturun
        PARTITION BY event_name
        ORDER BY km_traveled
    ) AS closest_concert_goer

FROM CONCERTS.attendance;

PARTITION BY, fonksiyonları uygulamak için kayıt pencereleri oluşturur

OVER(...) içinde ORDER BY'dan önce gelir
GROUP BY'a benzer, ancak kayıtları "çökertmez"

Bölümlerle veri sıralama

SELECT
    level,
    price,

    RANK() OVER(
        PARTITION BY level
        ORDER BY price DESC
    ) AS price_rank

FROM CONCERTS.attendance;

PARTITION BY pencereler oluşturur

      level  |   price   | price_rank 
    -------- | --------- | -----------
       100   |    765    |      1
       100   |    617    |      2
       100   |    490    |      3
       100   |    490    |      3

                  ...

       200   |    212    |      1
       200   |    207    |      2

                  ...

FIRST_VALUE ile özet metrikler üretme

    FIRST_VALUE(<1>) OVER(
        PARTITION BY <2>
        ORDER BY <3>
    ) AS <alias>

FIRST_VALUE, penceredeki ilk değeri bulur

<1>: döndürülecek sütun

<2>: veriyi bölecek alan

<3>: ilk kaydı belirleyen alan

AVG ile özet metrikler üretme

AVG(<1>) OVER(
    PARTITION BY <2>
    -- No need to ORDER BY!
) AS <alias>

AVG, her pencere için alanın ortalamasını hesaplar

<1>: ortalaması alınacak sütun

<2>: veriyi bölecek alan

... ORDER BY gerekmez!

Müşteri memnuniyeti

SELECT
    user_id, event_name, satisfaction_score,


    FIRST_VALUE(satisfaction_score) OVER(
        PARTITION BY event_name   -- En yakın konser katılımcısının memnuniyet puanı
        ORDER BY km_traveled
    ) AS first_score,


    -- Kayıtların bir "penceresi" için ortalama memnuniyet puanını bulun
    AVG(satisfaction_score) OVER(
        PARTITION BY event_name
    ) AS average_score


FROM CONCERTS.attendance;

Müşteri memnuniyeti


      user_id  |   event_name   |  satisfaction_score  |  first_score  |  average_score 
     --------- | -------------- | -------------------- | ------------- | ---------------

      user_26  |  Pulse Theory  |          71          |       98      |      84.5      
      user_92  |  Pulse Theory  |          98          |       98      |      84.5      

                                          ...

      user_57  |   Nova Sway    |           4          |       22      |      29.3      
      user_39  |   Nova Sway    |          22          |       22      |      29.3      
      user_44  |   Nova Sway    |          62          |       22      |      29.3      

                                          ...

Hadi pratik yapalım!

Snowflake'ta Pencere Fonksiyonları