MAP_UNION

功能概述

聚合函数，把多行 MAP 合并成一个 MAP，结果包含所有行中出现过的 key。适合把分散在多行的属性、配置、标签汇总为一个 MAP，例如合并同一用户多次上报的设备属性。

和 MAP_UNION_SUM 的区别：

MAP_UNION_SUM

MAP_UNION

语法

MAP_UNION(<map_expr>) [FILTER (WHERE <condition>)]

参数说明

• <map_expr>

  <map_expr>
  ：MAP 类型的列或表达式，value 可以是任意类型（包括 ARRAY 等复杂类型）。值为 NULL 的行被跳过。

  ⚠️ 注意：多行中出现相同 key 时，结果只保留其中一行的 value，具体是哪一行不确定。如果业务上需要确定的取值（如取最新值），先按规则去重再聚合。

• FILTER (WHERE <condition>)

  FILTER (WHERE <condition>)
  ：可选，只聚合满足条件的行。

返回类型与输入的 MAP 类型相同。

使用示例

合并多行 MAP，NULL 行被跳过：

SELECT map_union(a) AS merged FROM VALUES (map(1L, 'a')), (null), (map(2L, 'b')) AS t(a);

value 为复杂类型：

SELECT map_union(a) AS merged FROM VALUES (map('x', array(1, 2))), (map('y', array(3))) AS t(a);

map_from_entries(array_sort_by_key(map_entries(m), e -> e.key))

按分组合并，并用 FILTER 只聚合部分行。前置数据：

CREATE TABLE IF NOT EXISTS doc_map_union_attrs (user_id STRING, attrs MAP<STRING, STRING>, source STRING); INSERT INTO doc_map_union_attrs VALUES ('u1', map('os', 'iOS'), 'app'), ('u1', map('city', '上海'), 'web'), ('u1', map('lang', 'zh'), 'app'), ('u2', map('os', 'Android'), 'app');

SELECT user_id, map_union(attrs) AS all_attrs, map_union(attrs) FILTER (WHERE source = 'app') AS app_attrs FROM doc_map_union_attrs GROUP BY user_id ORDER BY user_id;

注意事项

• 相同 key 的 value 取值不确定。
• 结果 MAP 中 key 的顺序不保证。
• NULL 行被跳过，不影响其他行。

相关文档

• MAP_UNION_SUM：相同 key 的 value 求和
• MAP_AGG：把 key 列和 value 列聚合成 MAP
• MAP_CONCAT：合并同一行中的多个 MAP