[java] Java 8 스트림-수집 및 축소

그 이유는 간단합니다.

• collect() 만 사용할 수 있습니다 로 변경 가능한 결과 객체.
• reduce()되어 작동하도록 설계 와 불변의 결과 객체.

” reduce()불변의”예제

public class Employee {
  private Integer salary;
  public Employee(String aSalary){
    this.salary = new Integer(aSalary);
  }
  public Integer getSalary(){
    return this.salary;
  }
}

@Test
public void testReduceWithImmutable(){
  List<Employee> list = new LinkedList<>();
  list.add(new Employee("1"));
  list.add(new Employee("2"));
  list.add(new Employee("3"));

  Integer sum = list
  .stream()
  .map(Employee::getSalary)
  .reduce(0, (Integer a, Integer b) -> Integer.sum(a, b));

  assertEquals(Integer.valueOf(6), sum);
}

” collect()변경 가능”예제

예를 수동으로 사용하여 합계를 계산하려는 경우 collect()가 작동하지 수 BigDecimal있지만에서만 MutableInt에서 org.apache.commons.lang.mutable예를 들어. 보다:

public class Employee {
  private MutableInt salary;
  public Employee(String aSalary){
    this.salary = new MutableInt(aSalary);
  }
  public MutableInt getSalary(){
    return this.salary;
  }
}

@Test
public void testCollectWithMutable(){
  List<Employee> list = new LinkedList<>();
  list.add(new Employee("1"));
  list.add(new Employee("2"));

  MutableInt sum = list.stream().collect(
    MutableInt::new,
    (MutableInt container, Employee employee) ->
      container.add(employee.getSalary().intValue())
    ,
    MutableInt::add);
  assertEquals(new MutableInt(3), sum);
}

이것은 누산기 container.add(employee.getSalary().intValue()); 가 결과와 함께 새 객체를 반환하지 않고 containertype 의 mutable 상태를 변경해야하기 때문에 작동 합니다 MutableInt.

당신이 사용하려는 경우 BigDecimal대신 container사용 할 수 없습니다 당신 collect()으로 방법을 container.add(employee.getSalary());변경하지 않을 container때문에 BigDecimal불변이다. (이것 외에는 빈 생성자가 없으므로 BigDecimal::new작동하지 않습니다 BigDecimal)

답변

List<Integer> numbers = stream.reduce(
        new ArrayList<Integer>(),
        (List<Integer> l, Integer e) -> {
            l.add(e);
            return l;
        },
        (List<Integer> l1, List<Integer> l2) -> {
            l1.addAll(l2);
            return l1;
        });

streamDataFromFile(file)
            .map(data -> processData(data))
            .map(result -> database.save(result))
            .collect(Collectors.toList());

.reduce(0L, (aLong, result) -> aLong, (aLong1, aLong2) -> aLong1);

List<Integer> list = Arrays.asList(1,2,3,4,5,6,7);
int sum = list.stream().reduce((x,y) -> {
        System.out.println(String.format("x=%d,y=%d",x,y));
        return (x + y);
    }).get();

x=1,y=2
x=3,y=3
x=6,y=4
x=10,y=5
x=15,y=6
x=21,y=7
28

 For example, given a stream of Person, to calculate the longest last name
 of residents in each city:

    Comparator<String> byLength = Comparator.comparing(String::length);
    Map<String, String> longestLastNameByCity
        = personList.stream().collect(groupingBy(Person::getCity,
            reducing("", Person::getLastName, BinaryOperator.maxBy(byLength))));