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流合并分组内对象数据合并

WordPress中卸载插件以及移除文章类型组件的代码示例
这篇文章主要介绍了WordPress中卸载插件以及移除文章类型组件的代码示例,包括卸载函数钩子的方法介绍,需要的朋友可以参考下
2015-12-12
java读取邮件excel附件的方法过程示例
这篇文章主要介绍了java读取邮件excel附件的方法过程示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-10-10
Java实现简单登陆界面
这篇文章主要为大家详细介绍了Java实现简单登陆界面，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-04-04
springcloud pom.xml完整配置详解
这篇文章主要介绍了springcloud pom.xml完整配置，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-12-12
Spring Boot命令行运行器的实现方法
这篇文章主要介绍了Spring Boot命令行运行器的实现方法，非常不错，具有一定的参考借鉴价值,需要的朋友可以参考下
2018-10-10
Spring Boot2 整合连接 Redis的操作方法
在Spring Boot中,通过RedisTemplate可以方便地对Redis进行操作,包括设置和获取数据,文章详细介绍了如何配置RedisTemplate,创建RedisConfig类进行自定义配置,并通过Controller访问Redis数据库,感兴趣的朋友一起看看吧
2025-02-02
Java编程Post数据请求和接收代码详解
这篇文章主要介绍了Java编程Post数据请求和接收代码详解，涉及enctype的三种编码，post与get等相关内容，具有一定参考价值，需要的朋友可以了解下。
2017-11-11
springBoot启动时让方法自动执行的几种实现方式
这篇文章主要介绍了springBoot启动时让方法自动执行的几种实现方式，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-03-03
Intellij IDEA Debug调试技巧(小结)
这篇文章主要介绍了Intellij IDEA Debug调试技巧(小结)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-10-10
Java中的包(Package)与导入(Import)示例详解
这篇文章主要详细介绍了Java中的包（Package）和导入（Import）概念,包括包的定义、作用、JDK中主要的包、导入的目的与用法、特殊情况的导入、静态导入、包的访问权限和命名规范,文章通过丰富的解释和代码示例,帮助读者深入理解这些概念的实际应用,需要的朋友可以参考下
2024-11-11