• Stream

  • sequence of elements supporting sequential and parallel aggregate operations

  • 데이터를 담고 있는 저장소 (컬렉션)이 아니다.

  • Funtional in nature, 스트림이 처리하는 데이터 소스를 변경하지 않는다.

    Stream<String> stringStream = names.stream().map(String::toUpperCase);
    

    • 해당 코드에서 원본 names는 그대로이다.

  • 스트림으로 처리하는 데이터는 오직 한번만 처리한다.

  • 무제한일 수도 있다. (Short Circuit 메소드를 사용해서 제한할 수 있다.)

  • 중개 오퍼레이션은 근본적으로 lazy 하다.

    names.stream().map(s -> {
        System.out.println(s); 
        return s.toUpperCase();
    });
    

    • 해당 코드는 실행되지 않는다.
    • 중개 오퍼레이터들은 종료 오퍼레이터가 오기 전까진 실행하지 않는다.

  • 손쉽게 병렬 처리할 수 있다.

• 스트림 파이프라인
  • 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

public class OnlineClass {

    private Integer id;
    private String title;
    private boolean closed;

    public OnlineClass(Integer id, String title, boolean closed) {
        this.id = id;
        this.title = title;
        this.closed = closed;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public boolean isClosed() {
        return closed;
    }

    public void setClosed(boolean closed) {
        this.closed = closed;
    }
}

...

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));

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>> wooksangEvents = new ArrayList<>();
wooksangEvents.add(springClasses);
wooksangEvents.add(javaClasses);

• 걸러내기

  • Filter(Predicate)

    /*
    	Spring Class 중 title이 spring으로 시작하는 객체를 찾아서 title명을 출력
    */
    List<String> startsWithSpring = 
          springClasses.stream()
                  .filter(springClass -> springClass.getTitle().startsWith("spring"))
                  .map(springClass -> springClass.getTitle())
                  .collect(Collectors.toList());
    
    startsWithSpring.forEach(System.out::println);
    
    /*
    	Spring Class 중 종료되지 않은 수업을 찾아서 title을 출력
    */
    List<String> notClosedClass =
          springClasses.stream()
                  .filter(springClass -> !springClass.isClosed())
    							//.filter(Predicate.not(OnlineClass::isClosed)) 이렇게도 가능
                  .map(springClass -> springClass.getTitle())
                  .collect(Collectors.toList());
    
    notClosedClass.forEach(System.out::println);
    

• 변경하기

  • Map(Function) 또는 FlatMap(Function)

    /*
    	두 수업 목록에 들어있는 모든 수업 아이디 출력
    */
    wooksangEvents.stream()
            .flatMap(Collection::stream)
            .forEach(onlineClass -> System.out.println(onlineClass.getId()));
    
    /*
    	10부터 1씩 증가하는 무제한 스트림 중에서 앞에 10개 빼고 최대 10개 까지만 출력
    */
    Stream.iterate(10, i -> i + 1)
            .skip(10)
            .limit(10)
            .forEach(System.out::println);
    
    /*
    	자바 수업 중에 Test가 들어있는 수업이 있는지 확인
    */
    boolean test = javaClasses.stream()
            .anyMatch(onlineClass -> onlineClass.getTitle().contains("Test"));
    System.out.println(test);
    

    • 컬렉션 안에 컬렉션이 들어있는 경우 flatMap으로 평평하게(?) 만들어 하나의 컬렉션으로 만들 수 있다.

  • 예) 각각의 Post 인스턴스에서 String title만 새로운 스트림으로

  • 예) List<Stream<String>>을 String의 스트림으로

• 생성하기

  • generate(Supplier) 또는 Iterate(T seed, UnaryOperator)
  • 예) 10부터 1씩 증가하는 무제한 숫자 스트림
  • 예) 랜덤 int 무제한 스트림

• 제한하기

  • limit(long) 또는 skip(long)
  • 예) 최대 5개의 요소가 담긴 스트림을 리턴한다.
  • 예) 앞에서 3개를 뺀 나머지 스트림을 리턴한다.

• 스트림에 있는 데이터가 특정 조건을 만족하는지 확인

  • anyMatch(), allMatch(), nonMatch()
  • 예) k로 시작하는 문자열이 있는지 확인한다. (true 또는 false를 리턴한다.)
  • 예) 스트림에 있는 모든 값이 10보다 작은지 확인한다.

• 개수 세기

  • count()
  • 예) 10보다 큰 수의 개수를 센다.

• 스트림을 데이터 하나로 뭉치기

  • reduce(identity, BiFunction), collect(), sum(), max()
  • 예) 모든 숫자 합 구하기
  • 예) 모든 데이터를 하나의 List 또는 Set에 옮겨 담기

https://docs.oracle.com/javase/8/docs/api/java/util/stream/package-summary.html

https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html