스트림이란?
스트림은 데이터 소스를 추상화하고, 데이터를 다루는데 자주 사용되는 메서드들을 정의해 놓았다. 스트림을 이용하면 배열이나 컬렉션뿐만 아니라 파일에 저장된 데이터도 모두 같은 방식으로 다룰 수 있다.
스트림 특징
스트림은 데이터 소스를 변경하지 않는다.
스트림은 데이터 소스로부터 데이터를 읽기만할 뿐, 변경하지 않는다.
스트림은 일회용이다.
스트림은 Iterator처럼 일회용이다. 한 번 사용하면 닫혀서 사용할 수 없다.
필요 시 다시 생성하거나, 결과를 컬렉션이나 배열에 담아두고 사용할 수 있다.
스트림은 작업을 내부 반복으로 처리한다.
내부 반복을 통해 간결한 코드를 작성할 수 있다.
스트림의 사용방법
스트림 생성 : 데이터 소스로부터 스트림을 생성
중간 연산 : 원하는 형태로 데이터를 가공, 연속해서 연결할 수 있다.
최종 연산 : 원하는 형태로 반환
중간 연산
|
중간 연산
|
설명
|
|
Stream<T> distinct()
|
중복을 제거
|
|
Stream<T> filter()
|
조건에 안 맞는 요소 제외
|
|
Stream<T> limit()
|
스트림의 일부를 잘라낸다.
|
|
Stream<T> skip()
|
스트림의 일부를 건너뛴다.
|
|
Stream<T> peek()
|
스트림의 요소에 작업수행
|
|
Stream<T> sorted()
|
스트림의 요소를 정렬
|
|
Stream<R> map() DoubleStream mapToDouble() IntStream mapToInt() LongStream mapToLong()
|
스트림의 요소를 변환
|
|
Stream<R> flatMap() DoubleStream flatMapToDouble() IntStream flatMapToInt() LongStream flatMapToLong()
|
스트림의 요소를 변환
|
최종 연산
|
최종 연산
|
설명
|
|
void forEach() void forEachOrdered()
|
각 요소에 지정된 작업을 수행
|
|
long count()
|
스트림의 요소의 개수 반환
|
|
Optional<T> max() Optional<T> min()
|
스트림의 최대값/최소값 반환
|
|
Optional<T> findAny() // 아무거나 하나 Optional<T> findFirst() // 첫 번째 요소
|
스트림의 요소 하나를 반환
|
|
boolean allMatch() // 모두 만족 boolean anyMatch() // 하나라도 만족 boolean noneMatch() // 모두 만족x
|
주어진 조건을 모든 요소가 만족시키는지, 만족시키지 않는지 확인
|
|
Object[] toArray()
|
스트림의 모든 요소를 배열로 반환
|
|
Optional<T> reduce()
|
스트림의 요소를 하나씩 줄여가면서 계산
|
|
R collect()
|
스트림의 요소를 수집한다. 주로 요소를 그룹화하거나 분할한 결과를 컬렉션에 담아 반환하는데 사용된다.
|
병렬 스트림
병렬 스트림은 내부적으로 fork&join 프레임워크를 이용해서 자동적으로 연산을 병렬로 수행한다.
parallel() : 병렬로 연산을 수행하도록 지시
sequential() : 병렬로 처리되지 않게 한다.
parallel()과 sequential()은 새로운 스트림을 생성하는 것이 아니라, 스트림의 속성을 변경할 뿐이다.
스트림 요소 걸러내기 - filter(), distinct()
filter()는 매개변수로 Predicate를 필요로 하는데, 연산결과가 boolean인 람다식을 사용해도 된다.
정렬 - sorted()
문자열 스트림 정렬 방법
|
정렬 방법
|
출력 결과
|
|
sorted() // 기본정렬 sorted(Comparator.naturalOrder()) // 기본정렬 sorted((s1, s2)→s1.compareTo(s2)) // 람다식도 가능 sorted(String::compareTo)
|
CCaaabccdd
|
|
sorted(Comparator.reverseOrder()) // 기본정렬 역순 sorted(Comparator.<String>naturalOrder().reversed())
|
ddccbaaaCC
|
|
sorted(String.CASE_INSENSITIVE_ORDER) // 대소문자 구분x
|
aaabCCccdd
|
|
sorted(String.CASE_INSENSITIVE_ORDER.reversed())
|
ddCCccbaaa
|
|
sorted(Comparator.comparing(String::length)) // 길이 순 정렬 sorted(Comparator.comparingInt(String::length)) // no오토박싱
|
bddCCccaaa
|
|
sorted(Comparator.comparing(String::length).reversed())
|
aaaddCCccb
|
스트림 최종 연산
forEach()
스트림의 요소를 출력하는 용도로 사용되는 최종 연산이다.
조건 검사 - allMatch(), anyMatch(), noneMatch(), findFirst(), findAny()
모두 매개변수로 predicate를 요구하며, 연산결과로 boolean을 반환한다.
통계 - count(), sum(), average(), max(), min()
스트림의 변환
스트림 → 기본형 스트림
from
to
변환 메서드
|
Stream<T>
|
IntStream LongStream DoubleStream
|
mapToInt(Function<T> mapper) mapToLong(Function<T> mapper) mapToDouble(Function<T> mapper)
|
기본형 스트림 → 스트림
from
to
변환 메서드
|
IntStream LongStream DoubleStream
|
Stream<Integer> Stream<Long> Stream<Double>
|
boxed()
|
|
|
Stream<U>
|
mapToObj(Function<U> mapper)
|
기본형 스트림 → 스트림
from
to
변환 메서드
|
IntStream LongStream DoubleStream
|
LongStream DoubleStream
|
asLongStream() asDoubleStream()
|
스트림 → 부분 스트림
from
to
변환 메서드
|
Stream<T> IntStream
|
Stream<T> IntStream
|
skip(long n) limit(long maxSize)
|
두 개의 스트림 → 스트림
from
to
변환 메서드
|
Stream<T>
|
Stream<T>
|
concat(Stream<T> a, Stream<T> b)
|
|
IntStream
|
IntStream
|
concat(IntStream a, IntStream b)
|
|
LongStream
|
LongStream
|
concat(LongStream a, LongStream b)
|
|
DoubleStream
|
DoubleStream
|
concat(DoubleStream a, DoubleStream b)
|
스트림의 스트림 → 스트림
from
to
변환 메서드
|
Stream<Stream<T>>
|
Stream<T>
|
flatMap(Function mapper)
|
|
Stream<IntStream>
|
IntStream
|
flatMapToInt(Function mapper)
|
|
Stream<LongStream>
|
LongStream
|
flatMapToLong(Function mapper)
|
|
Stream<DoubleStream>
|
DoubleStream
|
flatMapToDouble(Function mapper)
|
스트림 → 병렬 스트림
from
to
변환 메서드
|
Stream<T>
|
Stream<T>
|
parallel() // 스트림 → 병렬 스트림
|
|
IntStream
|
IntStream
|
sequential() // 병렬 스트림 → 스트림
|
|
LongStream
|
LongStream
|
|
|
DoubleStream
|
DoubleStream
|
|
스트림 → 컬렉션
from
to
변환 메서드
|
Stream<T> IntStream LongStream DoubleStream
|
Collection<T> List<T> Set<T>
|
collect(Collectors.toCollection(Supplierfactory)) collect(Collertors.toList()) collect(Collectors.toSet())
|
컬렉션 → 스트림
from
to
변환 메서드
|
Collection<T>, List<T>, Set<T>
|
Stream<T>
|
stream()
|
스트림 → Map
from
to
변환 메서드
|
Stream<T> IntStream LongStream DoubleStream
|
Map<K, V>
|
collect(Collectors.toMap(Function key, Function value)) collect(Collectors.toMap(Function k, Function v, BinaryOperator)) collect(Collectors.toMap(Function k, Function v, BinaryOperator merge, Suppller mapSuppller))
|
스트림 → 배열
from
to
변환 메서드
|
Stream<T>
|
Object[] T[]
|
toArray() toArray(IntFunction<A[]> generator)
|
|
IntStream LongStream DoubleStream
|
int[] long[] double[]
|
toArray()
|