Share via

reduce 函式

  • 發行項

適用於：check marked yes Databricks SQL check marked yes Databricks Runtime

使用自訂匯總工具匯總數組中的專案。 此函式與聚合函數同義。

語法

reduce(expr, start, merge [, finish] )

引數

  • exprARRAY：表達式。
  • start：任何類型的初始值。
  • merge：用來匯總目前專案的 Lambda 函式。
  • finish：選擇性 Lambda 函式，用來完成匯總。

傳回

如果存在 或 start，則結果類型會比對 Lambda 函式的結果類型finish。

將表達式套用至初始狀態和數位中的所有專案，並將這縮減為單一狀態。 最終狀態會藉由套用 finish 函式轉換成最終結果。

函 merge 式會採用兩個參數。 第一個是累加器，第二個是要匯總的專案。 累加器和結果必須是的型別 start。 選擇性 finish 函式會採用一個參數，並傳回最終結果。

範例

> SELECT reduce(array(1, 2, 3), 0, (acc, x) -> acc + x);
 6
> SELECT reduce(array(1, 2, 3), 0, (acc, x) -> acc + x, acc -> acc * 10);
 60

> SELECT reduce(array(1, 2, 3, 4),
                named_struct('sum', 0, 'cnt', 0),
                (acc, x) -> named_struct('sum', acc.sum + x, 'cnt', acc.cnt + 1),
                acc -> acc.sum / acc.cnt) AS avg
 2.5