Java中stream流处理实现数据分组合并

更新时间：2026年03月10日 09:56:15 作者：不良手残

本文主要介绍了Java中stream流处理实现数据分组合并,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

期望效果

将下面的数据，根据project_number分组，合并生成一个新的数据结构

[
	{
		"bop_id": "1877304831014735872",
		"bop_name": "产品名称-wsas-1-衍生数据",
		"bop_number": "cil0000001177",
		"bop_rdmExtensionType": "ProjectProductBOP",
		"bop_rdmExtensionTypeCN": "产品名称",
		"project_id": "1872524834802634752",
		"project_name": "wsas-8005",
		"project_number": "P000000244",
		"project_rdmExtensionType": "Project",
		"project_rdmExtensionTypeCN": null
	},
	{
		"bop_id": "1878637661451849728",
		"bop_name": "产品名称-wsas-1",
		"bop_number": "cil0000001180",
		"bop_rdmExtensionType": "ProjectProductBOP",
		"bop_rdmExtensionTypeCN": "产品名称",
		"project_id": "1872524834802634752",
		"project_name": "wsas-8005",
		"project_number": "P000000244",
		"project_rdmExtensionType": "Project",
		"project_rdmExtensionTypeCN": null
	}
]

期望新的数据结构如下：

[
	{
		"project_id": "1872524834802634752",
		"project_name": "wsas-8005",
		"project_number": "P000000244",
		"project_rdmExtensionType": "Project",
		"project_rdmExtensionTypeCN": null,
		"bop": [
			{
				"bop_id": "1877304831014735872",
				"bop_name": "产品名称-wsas-1-衍生数据",
				"bop_number": "cil0000001177",
				"bop_rdmExtensionType": "ProjectProductBOP",
				"bop_rdmExtensionTypeCN": "产品名称"
			},
			{
				"bop_id": "1878637661451849728",
				"bop_name": "产品名称-wsas-1",
				"bop_number": "cil0000001180",
				"bop_rdmExtensionType": "ProjectProductBOP",
				"bop_rdmExtensionTypeCN": "产品名称"
			}
		]
	}
]

实现思路

将 List<BOPDataCheckVO> 按照 project_number 分组，并生成一个新的 List<UseDataCheckVO>。具体步骤如下：

检查输入列表是否为空：如果 bopDataCheckVOList 为空，直接返回空列表。
按项目编号分组：使用流式处理将BOPDataCheckVO 列表按 project_number 分组。
创建新的 UseDataCheckVO对象：对于每个分组，取第一个 BOPDataCheckVO 的信息填充到新的 UseDataCheckVO 对象中，并将整个分组的BOPDataCheckVO 列表赋值给 UseDataCheckVO 的 bopDataCheckVOs 属性。
收集结果：将所有生成的 UseDataCheckVO 对象收集到一个列表并返回。

源码

List<BOPDataCheckVO> ：

@Getter
@Setter
public class BOPDataCheckVO {

    public  String bop_id;
    public  String bop_name;
    public  String bop_number;
    public  String bop_rdmExtensionType;
    public  String bop_rdmExtensionTypeCN;
    public  String bop_versionIteration;

    public  String project_id;
    public  String project_name;
    public  String project_number;
    public  String project_rdmExtensionType;
    public  String project_rdmExtensionTypeCN;

    public String iteration;
    public String version;


    /**
     * 计算属性：得到完整的版本号：A.1
     * @return
     */
    public String getBop_versionIteration(){
        if (null == this.getVersion() || StrConstant.STRING_NULL.equals(this.getVersion()) || null == this.getIteration()) {
            return null;
        }
        return this.getVersion() + StrConstant.SYMBOL_DOT + this.getIteration();
    }

}

List<UseDataCheckVO>：

@Getter
@Setter
public class UseDataCheckVO {

    public  String project_id;
    public  String project_name;
    public  String project_number;
    public  String project_rdmExtensionType;
    public  String project_rdmExtensionTypeCN;

    public List<BOPDataCheckVO> bopDataCheckVOs;
}

核心处理方法：

/**
     * 将 List<BOPDataCheckVO> 以 project_number 分组合并，生成一个新的 List<UseDataCheckVO>
     * @param bopDataCheckVOList 输入的 BOPDataCheckVO 列表
     * @return 处理后的 UseDataCheckVO 列表
     */
    public List<UseDataCheckVO> mergeBOPDataCheckVOByProjectNumber(List<BOPDataCheckVO> bopDataCheckVOList) {
        if (org.apache.commons.collections4.CollectionUtils.isEmpty(bopDataCheckVOList)) {
            return Collections.emptyList();
        }
        return bopDataCheckVOList.stream()
                .collect(Collectors.groupingBy(BOPDataCheckVO::getProject_number))
                .entrySet().stream()
                .map(entry -> {
                    BOPDataCheckVO firstEntry = entry.getValue().get(0);
                    UseDataCheckVO useDataCheckVO = new UseDataCheckVO();
                    useDataCheckVO.setProject_id(firstEntry.getProject_id());
                    useDataCheckVO.setProject_name(firstEntry.getProject_name());
                    useDataCheckVO.setProject_number(firstEntry.getProject_number());
                    useDataCheckVO.setProject_rdmExtensionType(firstEntry.getProject_rdmExtensionType());
                    useDataCheckVO.setProject_rdmExtensionTypeCN(firstEntry.getProject_rdmExtensionTypeCN());
                    useDataCheckVO.setBopDataCheckVOs(entry.getValue());
                    return useDataCheckVO;
                })
                .collect(Collectors.toList());
    }

到此这篇关于Java中stream流处理实现数据分组合并的文章就介绍到这了,更多相关Java stream分组合并内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Java分析Lambda表达式Stream流合并分组内对象数据合并

Java多线程程序中synchronized修饰方法的使用实例
synchronized关键字主要北用来进行线程同步,这里我们主要来演示Java多线程程序中synchronized修饰方法的使用实例,需要的朋友可以参考下:
2016-06-06
Spring中校验器(Validator)的深入讲解
Spring校验器，参数校验从此简单。下面这篇文章主要给大家介绍了关于Spring中校验器(Validator)的相关资料，文中通过示例代码介绍非常详细，需要的朋友可以参考借鉴，下面随着小编来一起学习学习吧
2018-06-06
Java运算符>、>>、>>>三者的区别
这篇文章主要介绍了Java运算符>、>>、>>>三者的区别,做了一个简单的对比,并用实例说明,需要的朋友可以参考下
2014-06-06
Java中的逃逸问题心得
本篇文章是作者在学习了Java中的逃逸相关知识后的心得分享，一起跟着小编学习下。
2018-02-02
Springboot实现XSS漏洞过滤的示例代码
这篇文章主要介绍了Springboot实现XSS漏洞过滤的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-01-01
java环境变量如何配置
这篇文章主要为大家详细介绍了java环境变量配置教程，感兴趣的小伙伴们可以参考一下
2016-06-06
Java多线程之同步锁-lock详解
这篇文章主要为大家详细介绍了Java多线程中同步锁-lock的原理与使用，文中的示例代码讲解详细，对我们了解线程有一定帮助，需要的可以参考一下
2022-10-10
Java 中的 Function 接口案例讲解
Java8引入Function和Consumer函数式接口,用于处理输入输出及单参数操作,支持基本类型和多参数变体,应用于StreamAPI、策略模式及异常处理包装,提升代码简洁性与性能,本文给大家介绍Java中的Function接口案例,感兴趣的朋友一起看看吧
2025-06-06
java list去重操作实现方式
Java中的List是可以包含重复元素的(hash code 和equals)，接下来将介绍两种方式实现java list去重操作,感兴趣的朋友可以参考下
2012-12-12
一文掌握Springboot集成RabbitMQ的方法
RabbitMQ是开源的消息队列服务器,实现了AMQP高级消息队列协议标准,AMQP 是一种应用层协议,为面向消息的中间件设计,基于此协议的客户端与消息中间件可传递消息,并不受产品、开发语言等条件的限制,这篇文章主要介绍了Springboot集成RabbitMQ的过程,需要的朋友可以参考下
2024-04-04