首页spark sql group_concat

spark sql group_concat

时间: 2023-08-26 12:17:06 浏览: 302

MySQL拼接字符串函数GROUP_CONCAT详解

上一篇文章跨表更新，看到自己写的SQL像个憨憨写了关于跨表个更新的内容。一年过的很快，文中后来的两位员工馮大和馮二也要面对无情的 KPI 考核了，他们工作干的很不错，performance 分别是 4 和 5 新需求来了，静悄悄的来了！！！领导想要查看每个 performance 下都有谁，同时要求将这些人的名称要逗号拼接成一个字符串，也就是说要得到下面的结果：要将结果集中某个指定的列进行字符串拼接，这要怎么做呢？主角闪亮:sparkles:登场 GROUP_CONCAT(expr) 在 Mysql 官方文档中，该函数被放在聚合函数章节，如果你要按照指定字段分组拼接，就要配合关键字 GRO

Spark SQL中没有内置的group_concat函数，但可以使用concat_ws和collect_set或collect_list函数来实现类似的功能。在引用中的示例中，使用了concat_ws和collect_set函数来实现group_concat的效果。首先使用collect_set函数将相同age的name聚合到一个集合中，然后使用concat_ws函数将集合中的元素以逗号分隔拼接在一起。在引用中的示例中，也使用了collect_set函数来聚合name，只是此处使用的是agg函数来进行聚合操作。所以，你可以根据你的需求选择其中一种方法来实现spark sql的group_concat功能。123 #### 引用[.reference_title] - *1* *2* [Spark SQL 实现 group_concat](https://blog.csdn.net/Islotus/article/details/80994272)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"] - *3* [Spark SQL整合Hive与concat有关的三个函数concat()，concat_ws()，group_concat() 笔记](https://blog.csdn.net/m0_46168848/article/details/129430887)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"] [ .reference_list ]

阅读全文