分區由星火SQL多列

Question

火花SQL的窗口功能，我需要通過多個列進行分區來運行我的數據查詢，如下所示：

val w = Window.partitionBy($"a").partitionBy($"b").rangeBetween(-100, 0)

我目前還沒有一個測試環境（正在處理這些設置），但是作爲一個快速問題，目前是作爲Spark SQL窗口函數的一部分支持的，還是這不起作用？

Answer 1

這不起作用。第二個partitionBy將覆蓋第一個。兩個分區列必須在同一個調用中指定：

val w = Window.partitionBy($"a", $"b").rangeBetween(-100, 0)