如何实现基于DataFrame其他非零列的行值拼接及分组结果回写?
DataFrame列行值拼接实现规则
具体执行步骤
- 基础筛选条件:仅当参考列的行值不为0时,才将对应行的目标列取值纳入拼接范围,同类拼接的多个值之间以英文逗号分隔
- 分组依据:统一按
date字段完成分组聚合 - 分组内两类独立拼接计算:
- 筛选组内
x列值非零的行,提取这些行的colname列值,拼接为逗号分隔的字符串 - 筛选组内
y列值非零的行,提取这些行的colname列值,拼接为逗号分隔的字符串
- 筛选组内
- 新列生成:将以上两步得到的两个拼接字符串,以斜杠为分隔符拼接,生成新列
colname1 - 结果回写:将每个
date分组计算得到的colname1值,统一填充到该分组下的所有行
说明:需求对应的输入、输出样例逻辑已完成匹配校验,无外部跳转链接
内容的提问来源于stack exchange,提问作者sdsxiii
相关产品推荐
相关产品推荐

