Java中stream流处理实现数据分组合并
作者：不良手残
本文主要介绍了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分组合并内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！