Java 8 - накапливать и создавать новую коллекцию

Question

Использование java 8 Я хочу создать новую коллекцию из списка и накопить сумму на этом пути.

Список источников состоит из объектов, которые выглядят примерно так:

class Event { 
    String description; 
    double sum; 
} 

С примерным списком, как это:

{ { "desc1", 10.0 }, {"desc2", 14.0 }, {"desc3", 5.0 } } 

В результате список должен выглядеть следующим образом

• desc1, 10.0, 10.0
• desc2, 14.0, 24.0
• DESC3, 5,0, 29,0

Я знаю, как подвести итоги, чтобы получить окончательную сумму, в этом случае 29,0, но я хочу, чтобы создать список результатов и в то же время, накапливают сумму по пути ,

Как это сделать с помощью Java8?

Answer 1

Вы можете сделать это, реализовав свой собственный коллектор для выполнения сопоставления и суммирования. Ваш потоковый код будет выглядеть следующим образом:

List<SummedEvent> summedEvents = events.stream().collect(EventConsumer::new, EventConsumer::accept, EventConsumer::combine).summedEvents(); 
summedEvents.forEach((se) -> System.out.println(String.format("%s, %2f, %2f", se.description, se.sum, se.runningTotal))); 

Для этого я предполагал, новый класс SummedEvent который также держит нарастающий итог. Ваш класс коллектора будет затем реализовать что-то вроде этого:

class EventConsumer { 
    private List<SummedEvent> summedEvents = new ArrayList<>(); 
    private double runningTotal = 0; 

    public void accept(Event event) { 
     runningTotal += event.sum; 
     summedEvents.add(new SummedEvent(event.description, event.sum, runningTotal)); 
    } 
    public void combine(EventConsumer other) { 
     this.summedEvents.addAll(other.summedEvents); 
     this.runningTotal += other.runningTotal; 
    } 

    public List<SummedEvent> summedEvents() { 
     return summedEvents; 
    } 
} 

Answer 2

Если вы будете запускать трубопровод последовательно, вы можете использовать этот маленький хак с peek.

double[] acc = {0}; 
List<CustomEvent> list = originalList.stream() 
            .peek(e -> acc[0] += e.sum) 
            .map(e -> new CustomEvent(e, acc[0])) 
            .collect(toList()); 

Имейте в виду, что вы получите неправильные результаты, если поток работают параллельно.

Однако я не уверен, что если трубопровод может работать параллельно в один проход, но предполагая, что базовый список имеет быстрый доступ к элементу по индексу i вы можете сделать это следующим образом:

double[] acc = originalList.stream().mapToDouble(e -> e.sum).toArray(); 
Arrays.parallelPrefix(acc, Double::sum); 

List<CustomEvent> lx = IntStream.range(0, originalList.size()) 
           .parallel() 
           .mapToObj(i -> new CustomEvent(originalList.get(i), acc[i])) 
           .collect(toList()); 

parallelPrefix применит сокращение, которое вы ищете для сумм. Затем вам просто нужно передать индексы и сопоставить каждое событие с соответствующей накопленной суммой.