[JAVA] 25. 스트림의 최종 연산 (forEach(), reduce(), collect(), groupingBy(), partioningBy()..)

https://hyejin.tistory.com/605

[JAVA] 24. 스트림의 중간연산, Optional<T>, OptionalInt

 

 

1️⃣ 스트림의 최종 연산 

최종 연산은 스트림의 요소를 소모해서 결과를 만들어 낸다. 그래서 최종 연산 후에는 스트림이 닫히게 되고, 더 이상 사용할 수 없다. 

따라서 최종 연산의 결과는 스트림 요소의 합과 같은 단일 값이거나, 스트림의 요소가 담긴 배열 또는 컬렉션일 수 있다.

 

- forEach()

forEach()는 peek()과 달리 스트림의 요소를 소모하는 최종연산이다. 

반환 타입이 void이므로 스트림의 요소를 출력하는 용도로 많이 사용된다. 

 

- 조건 검사 allMatch(), anyMatch(), noneMatch(), findFirst(), findAny()

스트림의 요소에 대해 지정된 조건에 모든 요소가 일치하는 지, 일부가 일치하는지 아니면 어떤 요소도 일치하지 않는지 확인하는데 사용할 수 있는 메서드들이다. 

이 메서드들은 모두 매개변수로 Predicate를 요구하고 연산 결과로 boolean을 반환한다. 

이외에도 스트림의 요소 중에서 조건에 일치하는 첫 번째 것을 반환하는 FindFirst()가 있는데 주로 filter()와 함께 사용되어 조건에 맞는 스트림의 요소가 있는지 확인하는데 사용된다. 

병렬 스트림인 경우에는 findAny()를 사용한다. 

 

- 통계 count(), sum(), average(), max(), min()

 

 

- 리듀싱 reduce()

reduce()는 스트림의 요소를 줄여나가면서 연산을 수행하고 최종 결과를 반환한다. 

그래서 매개변수 타입이 BinaryOperator<T>이다. 처음 두 요소를 가지고 연산한 결과를 가지고 그 다음 요소와 연산한다. 

이 과정에서 스트림의 요소를 하나씩 소모하게 되며, 스트림의 모든 요소를 소모하게 되면 그 결과를 반환한다. 

reduce()를 사용하는 방법은 간단하다. 그저 초기값(identity)와 어떤 연산(BinaryOperator)으로 스트림의 요소를 줄여나갈 것인지만 결정하면 된다. 

 

 

 

 

2️⃣ Collect()

collect()는 스트림의 요소를 수집하는 최종 연산으로 앞에서 배운 리듀싱 reducing과 유사하다. 

collect()가 스트림의 요소를 수집하려면 어떻게 수집할 것인가에 대한 방법이 정의되어 있어야 하는데, 이 방법을 정의한 것이 바로 컬렉터 Collector이다. 

collect() : 스트림의 최종 연산, 매개변수로 컬렉터를 필요로 한다.
Collector : 수집에 필요한 메서드를 정의해 놓은 인터페이스
Collectors : 다양한 기능의 Collector를 구현한 클래스, static메서드로 미리 작성된 컬렉터를 제공한다. 

 

 

- 스트림을 컬렉션과 배열로 변환 toList(), toSet(), toMap(), toCollection(), toArray()

스트림의 모든 요소를 컬렉션에 수집하려면, Collectors클래스의 toList()와 같음 메서드를 사용하면 된다. 

p- p.getRegId() 는 key, p->p는 항등함수로 입력그대로 출력 하는 것으로 이를 value로 한다. 

 

그리고 스트림에 저장된 요소들을 T[] 타입의 배열로 변환하려면 toArray()를 사용하면 된다. 

단, 해당 타입의 생성자 참조를 매개변수로 지정해줘야 한다. 

Student[] stuNames = studentStream.toArray(Student[]::new);  -> O 

Object[] stuNams = StudentStream.toArray(); -> O 

Student[] stuNames = StudentStream.toArray(); -> X

 

 

- 통계 counting(), summingInt(), averagingInt(), maxBy(), minBy()

Collectors는 static import로 생략했다는 가정

 

- 리듀싱 reducing

 

- 문자열 결합 joining()

: 문자열 스트림의 모든 요소를 하나의 문자열로 연결해서 반환한다. 

이때 스트림의 요소가 문자열이 아닌 경우에는 map()을 이용해서 먼저 스트림의 요소를 문자열로 변환해야 한다. 

 

 

 

3️⃣  그룹화와 분할 groupingBy(), partitioningBy()

그룹화는 스트림의 요소를 특정 기준으로 그룹화하는 것을 의미하고, 분할은 스트림의 요소를 두가지, 지정된 조건에 일치하는 그룹과 일치하지 않는 그룹으로의 분할을 의미한다. 

groupingBy()는 스트림의 요소를 Function으로, partitioningBy()는 Predicate로 분류한다. 

스트림을 두 개의 그룹으로 나눠야 한다면 partitioningBy()로 분할하는것이 훨씬 빠르다!

 

 

- partitioningBy()에 의한 분류

 

 

 

- groupingBy()에 의한 분류

-> 마지막에는 학년별과 반별로 그룹화한 다음에, 성적그룹으로 변환mapping하여 Set에 저장한다. 

 

-> 학년별, 반 별로 그룹화 한 다음에, 성적 그룹으로 변환mapping하여 Set에 저장한다. 

 

 

 

- 스트림 변환 메서드