WindowSpecで複数の範囲句を定義する方法は？

Question

SparkSQLでは、2列以上の列でウィンドウクエリを定義することはできますが、これらの列に基づいてrange句を定義することはできないようです。

例えば、

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 

上記は失敗（おそらく構文はオフですが？指が交差...）

それは、上記と同様の単一のステートメントで行うことができますか？

Answer 1

いいえ、1つの範囲のみが許可されます。しかし、絶望しないでください。 count(*)は添加物である：

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 

範囲が重複しているので、この特定の例では、好奇心旺盛ようです。多分それがあなたの意図です。

したい場合は、あなたの質問に基づいて、私は疑問に思う：

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