events
aggregate
関数
適用対象: Databricks SQL Databricks Runtime
カスタム アグリゲーターを使用して、配列内の要素を集計します。 この関数は、reduce 関数のシノニムです。
aggregate(expr, start, merge [, finish])
expr
: ARRAY 式。start
: 任意の型の初期値。merge
: 現在の要素を集計するために使用されるラムダ関数。finish
: 集計を完了するために使用されるラムダ関数 (省略可能)。
結果の型は、finish
ラムダ関数の結果の型 (存在する場合) または start
と一致します。
式を初期状態と配列内のすべての要素に適用して、これを 1 つの状態に絞り込みます。 最終状態は、finish
関数を適用することによって最終的な結果に変換されます。
merge
関数は、2 つの parametersを受け取ります。 1 つ目はアキュムレータで、2 つ目は集計される要素です。
アキュムレータと結果は、start
の型である必要があります。
省略可能な finish
関数は、1 つのパラメーターを受け取り、最終的な結果を返します。
> SELECT aggregate(array(1, 2, 3), 0, (acc, x) -> acc + x);
6
> SELECT aggregate(array(1, 2, 3), 0, (acc, x) -> acc + x, acc -> acc * 10);
60
> SELECT aggregate(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
その他のリソース
トレーニング
モジュール
Kusto 照会言語を使用してデータから分析情報を取得する - Training
集計関数、レンダリング演算子、および変数を使用して、Kusto クエリ言語 (KQL) で高度なクエリを作成する方法を学習します。
ドキュメント
-
array_distinct 関数 - Azure Databricks - Databricks SQL
Databricks SQL と Databricks Runtime での SQL 言語の array_distinct 関数の構文について説明します。
-
ウィンドウ関数 - Azure Databricks - Databricks SQL
Databricks SQL と Databricks Runtime の SQL 言語でウィンドウ関数を使用する方法について説明します。
-
sum 集計関数 - Azure Databricks - Databricks SQL
Databricks SQL と Databricks Runtime の SQL 言語の sum 集計関数の構文について説明します。