FOREACH

description

テーブル用の集約関数を配列用の集約関数に変換し、対応する配列項目を集約して結果の配列を返します。例えば、配列 [1, 2]、[3, 4, 5]、[6, 7] に対する sum_foreach は、対応する配列項目を加算した後、結果 [10, 13, 5] を返します。

Syntax

AGGREGATE_FUNCTION_FOREACH(arg...)

example

サンプルデータを準備します：

CREATE TABLE db (
    id INT,
    a  ARRAY<INT>,
    s  ARRAY<STRING>
)
DUPLICATE KEY(id)
DISTRIBUTED BY HASH(id) BUCKETS 1
PROPERTIES ("replication_num" = "1");

INSERT INTO db VALUES
    (1, [1, 2, 3], ["ab", "123"]),
    (2, [20],      ["cd"]),
    (3, [100],     ["efg"]),
    (4, NULL,      NULL),
    (5, [null, 2], [null, "c"]);

その後、FOREACH コンビネータを実行します：

mysql [test]>select a , s from db;
+-----------+---------------+
| a         | s             |
+-----------+---------------+
| [1, 2, 3] | ["ab", "123"] |
| [20]      | ["cd"]        |
| [100]     | ["efg"]       |
| NULL      | NULL          |
| [null, 2] | [null, "c"]   |
+-----------+---------------+

mysql [test]>select sum_foreach(a) from db;
+----------------+
| sum_foreach(a) |
+----------------+
| [121, 4, 3]    |
+----------------+

mysql [test]>select count_foreach(s) from db;
+------------------+
| count_foreach(s) |
+------------------+
| [3, 2]           |
+------------------+

mysql [test]>select array_agg_foreach(a) from db;
+-----------------------------------+
| array_agg_foreach(a)              |
+-----------------------------------+
| [[1, 20, 100, null], [2, 2], [3]] |
+-----------------------------------+

mysql [test]>select map_agg_foreach(a,a) from db;
+---------------------------------------+
| map_agg_foreach(a, a)                 |
+---------------------------------------+
| [{1:1, 20:20, 100:100}, {2:2}, {3:3}] |
+---------------------------------------+

注意事項

• 各引数は、ネストされた集約関数の対応する引数と要素型が一致するARRAYでなければなりません。結果は、ネストされた関数の戻り値型のARRAYで、位置ごとに計算されます。
• 単一の呼び出しで複数のarray引数を渡す場合、同じ行内のすべてのarrayは同じ長さでなければなりません。そうでない場合、クエリはArrays passed to <function> aggregate function have different sizesで失敗します。（Array長は行間で異なっても構いません。）
• percentile、percentile_array、percentile_approx、およびpercentile_approx_weighted関数は、foreachコンビネータではサポートされていません。

keywords

FOREACH