实体类包含了所有的字段
package com.leo;
import lombok.Data;
import java.io.Serializable;
@Data
public class TestObj implements Serializable {
private static final long serialVersionUID = 1L;
String provinceId;
String field1;
String field2;
String field3;
String field4;
String field5;
String field6;
String field7;
String field8;
String field9;
* 测试类
@Test
public void streamConcat2() {
TestObj t0 = new TestObj();
t0.setProvinceId("000");
t0.setField1("1");
t0.setField2("2");
t0.setField3("3");
TestObj t1 = new TestObj();
t1.setProvinceId("100");
t1.setField1("1");
t1.setField2("2");
t1.setField3("3");
TestObj t2 = new TestObj();
t2.setProvinceId("100");
t2.setField4("4");
t2.setField5("5");
t2.setField6("6");
TestObj t3 = new TestObj();
t3.setProvinceId("100");
t3.setField7("7");
t3.setField8("8");
t3.setField9("9");
TestObj t4 = new TestObj();
t4.setProvinceId("102");
t4.setField7("7");
t4.setField8("8");
t4.setField9("9");
List<TestObj> list1 = new ArrayList<>();
list1.add(t0);
list1.add(t1);
List<TestObj> list2 = new ArrayList<>();
list2.add(t2);
List<TestObj> list3 = new ArrayList<>();
list3.add(t3);
list3.add(t4);
List<TestObj> list = Stream.concat(Stream.concat(list1.stream(), list2.stream()), list3.stream())
.filter(e -> e != null)
.collect(Collectors.toMap(TestObj::getProvinceId, a -> a, (o1, o2) -> {
try {
BeanUtil.copyProperties(o1, o2, CopyOptions.create().setIgnoreNullValue(true).setIgnoreError(true));
} catch (Exception e) {
e.printStackTrace();
return o2;
})).values().stream().collect(Collectors.toList());
list.stream().forEach(System.out::println);
测试结果:
TestObj(provinceId=000, field1=1, field2=2, field3=3, field4=null, field5=null, field6=null, field7=null, field8=null, field9=null)
TestObj(provinceId=100, field1=1, field2=2, field3=3, field4=4, field5=5, field6=6, field7=7, field8=8, field9=9)
TestObj(provinceId=102, field1=null, field2=null, field3=null, field4=null, field5=null, field6=null, field7=7, field8=8, field9=9)
以每个省id作为进行数据分组,一个省只有一行数据,将其他有值的字段合并到这一行数据上
最终实现的效果是返回一个最终的list,里面的每一个实体值是上面所有字段合并后的值(provinceId、field1、field2、field3、field4、field5、field6、field7、field8、field9)A接口返回List里面有值的的字段为:provinceId、field1、field2、field3。B接口返回List里面有值的的字段为:provinceId、field4、field5、field6。数据出自许多接口数据,需要将几个接口数据根据省份id进行分组合并。
项目中有个需求:需要将list<CmdVo> 根据cmd字段分组后再转换成list<Params>。虽然需求有点脑残,主要记录下stream流的使用吧。使用stream流转换真的很方便。
@Data
public class CmdVo {
private String cmd;
private String param;
private Object value;
@Data
public class Param {
privat
回答: 在使用Stream流进行计算时,可以使用Lambda表达式来定义计算逻辑。Lambda表达式可以作为参数传递给Stream流的各种方法,以实现不同的计算操作。例如,可以使用forEach方法来逐一处理流中的元素,使用filter方法来过滤流中的元素,使用map方法来映射流中的元素,使用count方法来统计流中的元素个数,使用limit方法来取用前几个元素,使用skip方法来跳过前几个元素,使用concat方法来组合多个流。[2]示例代码中的Stream.concat方法就是使用Lambda表达式将两个流进行合并。在这个例子中,streamA和streamB是两个包含字符串的流,通过Stream.concat(streamA, streamB)可以将它们合并成一个新的流result。[3]