stream
•
데이터를 담고 있는 저장소(컬렉션)가 아니다.
•
Functional in nature, 스트림이 처리하는 데이터 소스를 변경하지 않는다.
•
스트림으로 처리하는 데이터는 오직 한번만 처리한다.
•
무제한일 수도 있다. (Short Circuit 메서드를 사용해서 제한할 수 있다)
중개 오퍼레이션은 근본적으로 lazy하다.
•
손쉽게 병렬처리할 수 있다.
스트림 파이프라인
•
0 또는 다수의 중개 오퍼레이션(intermediate operation)과 한 개의 종료 오퍼레이션(terminal operation)으로 구성한다.
•
스트림의 데이터 소스는 오직 터미널 오퍼레이션을 실행할 때에만 처리한다.
중개 오퍼레이션
•
Stream을 리턴한다.
•
Stateless / Stateful 오퍼레이션으로 더 상세하게 구분할 수도 있다.
(대부분은 Stateless지만 distinct나 sorted처럼 이전 소스 데이터를 참조해야 하는 오퍼레이션은 Stateful 오퍼레이션이다.)
•
filter, map, limit, skip, sorted, …
종료 오퍼레이션
•
Stream을 리턴하지 않는다.
•
collect, allMatch, count, forEach, min, max, …
참고
Stream API 종류
걸러내기
변경하기
생성하기
제한하기
스트림에 있는 데이터가 특정 조건을 만족하는지 확인
개수 세기
스트림을 데이터 하나로 뭉치기
실습예제
List<OnlineClass> springClasses = new ArrayList<>();
springClasses.add(new OnlineClass(1, "spring boot", true));
springClasses.add(new OnlineClass(2, "spring data jpa", true));
springClasses.add(new OnlineClass(3, "spring mvc", false));
springClasses.add(new OnlineClass(4, "spring core", false));
springClasses.add(new OnlineClass(5, "rest api development", false));
//1. spring 으로 시작하는 수업
springClasses.stream()
.filter(oc -> oc.getTitle().startsWith("spring"))
.forEach(oc -> System.out.println(oc.getId()));
//2. close 되지 않은 수업
springClasses.stream()
.filter(Predicate.not(OnlineClass::isClosed)) //메서드 레퍼런스
.forEach(oc -> System.out.println(oc.getId()));
//3. 수업 이름만 모아서 스트림 만들기
springClasses.stream()
.map(OnlineClass::getTitle) //메서드 레퍼런스
.forEach(System.out::println); //메서드 레퍼런스
///////////////////////////////////
List<OnlineClass> javaClasses = new ArrayList<>();
javaClasses.add(new OnlineClass(6, "The Java, Test", true));
javaClasses.add(new OnlineClass(7, "The Java, Code manipulation", true));
javaClasses.add(new OnlineClass(8, "The Java, 8 to 11", false));
List<List<OnlineClass>> jaewoongEvents = new ArrayList<>();
jaewoongEvents.add(springClasses);
jaewoongEvents.add(javaClasses);
///////////////////////////////////
//4. 두 수업 목록에 들어있는 모든 수업 아이디 출력
jaewoongEvents.stream().flatMap(Collection::stream)
.forEach(oc -> System.out.println(oc.getId()));
//5. 10부터 1씩 증가하는 무제한 스트림 중에서 앞에 10개 빼고 최대 10개 까지만
Stream.iterate(10, i -> i + 1)
.skip(10)
.limit(10)
.forEach(System.out::println);
//6. 자바 수업 중에 Test가 들어있는 수업이 있는지 확인
javaClasses.stream().anyMatch(oc -> oc.getTitle().contains("Test"));
//7. 스프링 수업 중에 제목에 spring이 들어간 제목만 모아서 List로 만들기
springClasses.stream()
.filter(oc -> oc.getTitle().contains("spring"))
.map(OnlineClass::getTitle)
.collect(Collectors.toList());
Java
복사
