Stream API

Stream API

걸러내기

• Filter(Predicate)
  • Predicate는 자바 11부터 사용가능
• 예) 이름이 3글자 이상인 데이터만 새로운 스트림으로 

 

오라클 1.8, 여러가지 OpenJDK를 사용해본결과 1.8에는 없어서 질문했는데 답변을 달아주셨다...

11버전부터는 1.8과 몇가의 메소드들이 달라진것 같다.

공부하자!

 

 

변경하기

• Map(Function) 또는 FlatMap(Function)
• 예) 각각의 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에 옮겨 담기

 

 

 

예제

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;


public class AppRun {

	public static void main(String[] args) {
		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 developement", 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", true));

		List<List<OnlineClass>> jinSeokEvents = new ArrayList<>();
		jinSeokEvents.add(springClasses);
		jinSeokEvents.add(javaClasses);

		System.out.println("spring 으로 시작하는 수업");
		springClasses.stream()
				.filter(oc -> oc.getTitle().startsWith("spring"))
				.forEach(oc -> System.out.println(oc.getTitle()));

		System.out.println("====================================");
		
		System.out.println("close 되지 않은 수업");
		springClasses.stream()
			.filter(oc -> !oc.isClosed()) 
//			.filter(OnlineClass::isClosed) // 메소드 래퍼런스 이용
//			.filter(Predicate.not(OnlineClass::isClosed))
			.forEach(oc -> System.out.println(oc.getTitle()));
		
		System.out.println("====================================");
		System.out.println("수업 이름만 모아서 스트림 만들기");
		springClasses.stream()
//			.map(oc -> oc.getTitle()) 
			.map(OnlineClass::getTitle) // 메소드 래퍼런스 이용
			.forEach(oc -> System.out.println(oc));
		
		System.out.println("====================================");
		System.out.println("두 수업 목록에 들어있는 모든 수업 아이디 출력");
		jinSeokEvents.stream()
//			.flatMap(list -> list.stream())
			.flatMap(Collection::stream)
			.forEach(oc -> System.out.println(oc.getId()));
		
		// 아래는 작성하지 못한다.
		// 그 이유는 jinSeokEvents는 2개의 리스트가 합친 것이므로
		// 하나로 만들지 못했기 때문이다.
		// flatMap을 사용하면 각 리스트의 요소들을 꺼내기 때문에
		// 오류가 발생되지 않는다.
//		jinSeokEvents.stream()
//				.forEach(oc -> System.out.println(oc.getId()));
		
		
		System.out.println("====================================");
		System.out.println("10부터 1씩 증가하는 무제한 스트림 중에서 앞에 10개 빼고 최대 10개까지만");
		Stream.iterate(10, i -> i + 1)
			.skip(10)
			.limit(10)
//			.forEach(i -> System.out.println(i));
			.forEach(System.out::println);
		
		
		System.out.println("====================================");
		System.out.println("자바 수업 중에 Test가 들어있는 수업이 있는지 확인");
		boolean test =  javaClasses.stream().anyMatch(oc -> oc.getTitle().contains("Test"));
		System.out.println(test);
		
		
		System.out.println("====================================");
		System.out.println("스프링 수업 중에 제목이 spring이 들어간 제목을 모아서 List만들기");
		List<String> spring = springClasses.stream()
			.filter(oc -> oc.getTitle().contains("spring"))
			.map(oc -> oc.getTitle())
			.collect(Collectors.toList());
		spring.forEach(System.out::println);
		
	}
}