更好的方法进行流和？

Question

我有一个对象

public class Sample {
   private String Id;
   ...
   private String acct;
   private BigDecimal amt1;
   private BigDecimal amt3;
}

，我想从列表

Id | acct  |  amt1   |  amt2   
1  |  1111  |  0.50   |  0.50 
2  |  1112  |  0.50   |  0.50 

中总结AMT1和AMT2的

Map<Object, Sample> map = collectedTxs.stream()
        .collect(Collectors.toMap(
            f -> f.getAcct(),
            Function.identity(),
            (s, a) -> new Sample(
                s.getId(),
                s.getAcct(),
                s.getAmt1().add(a.getAmt1()),
                s.getAmt2().add(a.getAmt2()),
            ), LinkedHashMap::new));

列表有什么更好的方法吗？我不想将结果重新分配到另一个示例对象。

Answer 1

我不想将结果重新分配到另一个示例对象。

流旨在用于映射值。不建议在流环境外修改现有状态，因为它可能在某些情况下导致数据不一致。但是，您仍然可以使用Java 8+地图功能非常有效地做到这一点。 （流并不总是操纵数据的最佳或最有效的方法。使用循环没有错。）

这是我的做法。这是唯一更改的班级定义。

• 静态副本方法返回复制实例（根据 mcemperor ）。
• 添加值并返回当前实例的添加方法。

static class Sample {
    private String Id;
    private String acct;
    private BigDecimal amt1;
    private BigDecimal amt2;
    public Sample(String id, String acct, BigDecimal amt1,
            BigDecimal amt2) {
        Id = id;
        this.acct = acct;
        this.amt1 = amt1;
        this.amt2 = amt2;   
    }
    
    public Sample(Sample sample) {
        this(sample.Id, sample.acct,sample.amt1,sample.amt2);
    }
    
    public static Sample copyOf(Sample s) {
        return new Sample(s.Id, s.acct, s.amt1,s.amt2);
    }
    
    public Sample add(Sample sample) {
        amt1 = amt1.add(sample.amt1);
        amt2 = amt2.add(sample.amt2);
        return this;
    }
    // other getters and setters
    public void setId(String id) {
        Id = id;
    }
    
    public void setAcct(String acct) {
        this.acct = acct;
    }
    
    public void setAmt1(BigDecimal amt1) {
        this.amt1 = amt1;
    }
    
    public void setAmt2(BigDecimal amt2) {
        this.amt2 = amt2;
    }
    
    public String getId() {
        return Id;
    }
    
    public String getAcct() {
        return acct;
    }
    
    public BigDecimal getAmt1() {
        return amt1;
    }
    
    public BigDecimal getAmt2() {
        return amt2;
    }

    @Override
    public String toString() {
        return String.format("[%s, %s, %s, %s]", Id, acct, amt1,
                amt2);
    }
    
}

数据

List<Sample> collectedTxs = List.of(
        new Sample("1", "1111", new BigDecimal(".50"),
                new BigDecimal(".50")),
        new Sample("2", "1112", new BigDecimal(".50"),
                new BigDecimal(".50")),
        new Sample("2", "1112", new BigDecimal("1.50"),
                new BigDecimal("2.50")),
        new Sample("1", "1111", new BigDecimal("4.50"),
                new BigDecimal("8.50")));

流程

• 在帐户列表上迭代。
• 并使用合并方法结合相同的帐户。
• ACCT是密钥
• s是每个帐户的第一个遇到的实例。
• 双方函数通过添加使用方法参考

Map<String,Sample> map = new HashMap<>();
for (Sample s : collectedTxs) {
    map.merge(s.getAcct(), s, Sample::add);
}


map.forEach((k,v)-> System.out.println(k + " " + v);

prints

1112 [2, 1112, 2.00, 3.00]
1111 [1, 1111, 5.00, 9.00]

将它们结合在一起，这是原始数据。请注意，迭代中遇到的第一个帐户已更改。

collectedTxs.forEach(System.out::println);

[1, 1111, 5.00, 9.00]
[2, 1112, 2.00, 3.00]
[2, 1112, 1.50, 2.50]
[1, 1111, 4.50, 8.50]

如果您想保留原始实例。然后在地图构造中进行以下更改。

map.merge(s.getAcct(),  Sample.copyOf(s), Sample::add);