例如:

select periodical_code,
sort_array(collect_set(
    concat(
        "{",
        concat(
            concat("\"", p_year, "\""),
            ":",
            concat("\"", p_year_stage, "\"")
        ),
        "}"
    )
)) as year_stage_set
from ods_medical group by periodical_code;

这边使用了hive中的3个函数,concat、collect_set、sort_array

1、cancat 可以将多个字符串连接

2、collect_set 可以将分组后的数据一条一条收集成一个array,而且会去除重复数据

3、sort_array 可以对一个array中的所有元素进行字典序排序

Logo

北京人形旗下天工造物具身智能开源社区,聚焦具身天工与慧思开物两大平台

更多推荐