Wie definiert man mehrere Bereichsklauseln in WindowSpec?

Question

In SparkSQL ist es möglich, eine Fensterabfrage mit Spalten 2+ nach Spalten zu definieren, aber es scheint nicht möglich zu sein, Bereichsklauseln basierend auf diesen Spalten zu definieren.

Zum Beispiel

select 
row_id, 
count(*) over (
    partition by group_id 
    order by filter_key1, filter_key2 
    range between 12 preceding and 12 following 
    range between 5 preceding and 1 preceding 
) as the_count 
from table 

Die obige fehlschlägt (wenn auch vielleicht die Syntax aus? Daumen ...)

Kann es in einer einzigen Anweisung ähnlich der oben getan werden?

Answer 1

Nein, nur ein Bereich ist erlaubt. Aber verzweifle nicht. count(*) ist additiv:

select row_id, 
     (count(*) over (partition by group_id 
         order by filter_key1, filter_key2 
         range between 12 preceding and 12 following 
        ) + 
     count(*) over (partition by group_id 
         order by filter_key1, filter_key2 
         range between 5 preceding and 1 preceding 
        ) 
     ) as the_count 
from table 

Dieses spezielle Beispiel scheint neugierig, weil die Bereiche überlappen. Vielleicht ist das deine Absicht.

Basierend auf Ihrer Frage, frage ich mich, wenn Sie wollen:

select row_id, 
     (count(*) over (partition by group_id 
         order by filter_key1 
         range between 12 preceding and 12 following 
        ) + 
     count(*) over (partition by group_id 
         order by filter_key2 
         range between 5 preceding and 1 preceding 
        ) 
     ) as the_count 
from table