メインコンテンツまでスキップ
に最終更新

MAP_AGG

説明​

MAP_AGG 関数は、複数行のキーと値の組から MAP を作成します。

キーが重複する場合、MAP_AGG は集約中に最初に処理した値を保持し、すでに存在するキーの後続の値を無視します。部分集約の状態をマージする際も、マージ先の状態にすでに存在する値が保持されます。

「最初に処理した」とは処理順序を指し、挿入順序を指すものではありません。スキャン、並列実行、部分集約の状態をマージする順序によって保持される値が変わる可能性があるため、重複キーに対して選ばれる値がクエリ間で同じになるとは限りません。外側の ORDER BY は結果の行を並べ替えるだけで、重複キーに対して保持される値は決定しません。

構文​

MAP_AGG(<expr1>, <expr2>)

パラメータ​

パラメータ説明
<expr1>キーとして使用する式。対応する型: Bool、TinyInt、SmallInt、Integer、BigInt、LargeInt、Float、Double、Decimal、Date、Datetime、String。
<expr2>値として使用する式。対応する型: Bool、TinyInt、SmallInt、Integer、BigInt、LargeInt、Float、Double、Decimal、Date、Datetime、String。

戻り値​

Map 型の値を返します。グループ内に有効なデータがない場合は、空の Map を返します。

例​

-- setup
CREATE TABLE nation (
    n_nationkey INT,
    n_name STRING,
    n_regionkey INT
) DISTRIBUTED BY HASH(n_nationkey) BUCKETS 1
PROPERTIES ("replication_num" = "1");
INSERT INTO nation VALUES
    (0, 'ALGERIA', 0),
    (1, 'ARGENTINA', 1),
    (2, 'BRAZIL', 1),
    (3, 'CANADA', 1);
select `n_regionkey`, map_agg(`n_nationkey`, `n_name`) from `nation` group by `n_regionkey`;
+-------------+-----------------------------------------+
| n_regionkey | map_agg(`n_nationkey`, `n_name`)        |
+-------------+-----------------------------------------+
|           0 | {0:"ALGERIA"}                           |
|           1 | {1:"ARGENTINA", 2:"BRAZIL", 3:"CANADA"} |
+-------------+-----------------------------------------+
select map_agg(`n_name`, `n_nationkey` % 5) from `nation`;
+------------------------------------------------------+
| map_agg(`n_name`, `n_nationkey` % 5)                 |
+------------------------------------------------------+
| {"ALGERIA":0, "ARGENTINA":1, "BRAZIL":2, "CANADA":3} |
+------------------------------------------------------+
select map_agg(`n_name`, `n_nationkey` % 5) from `nation` where n_nationkey is null;
+--------------------------------------+
| map_agg(`n_name`, `n_nationkey` % 5) |
+--------------------------------------+
| {}                                   |
+--------------------------------------+

次のクエリには重複するキーが含まれるため、結果に含まれるキーと値の組は一つだけです。最初に処理される値に応じて、結果は {1:"a"} または {1:"b"} になります。出力例を以下に示します。

SELECT MAP_AGG(k, v) AS result
FROM (
    SELECT 1 AS k, 'a' AS v
    UNION ALL
    SELECT 1 AS k, 'b' AS v
) AS input;
+---------+
| result  |
+---------+
| {1:"a"} |
+---------+
Report issue