[Stream API] 스트림 중간연산 (2/3)

 

 

1. 변환 - map()

스트림 요소중 특정 필드만 뽑아내거나 특정 형태로 변환시 사용

 

Stream<R> map (Function<? super T, ? extends R > mapper)

/**
* File의 스트림에서 파일명만 뽑아내고 싶을 때
**/
Stream<File> fileStream = Stream.of(new File("Ex1.java"), new File("Ex1"),
                		new File("Ex1.bak"), new File("Ex2.java"),
                		new File("Ex1.txt"));
    
// Stream<File> -> Stream<String> 으로 변환
Stream<String> fileNameStream = fileStream.map(File::getName);
fileNameStream.forEach(System.out::println);


// map() 함수는 filter() 함수 처럼 여러번 사용할 수 있음
// s.indexOf("") : 해당 char의 index 값 반환, 없으면 -1 반환

fileStream.map(File::getName)                   // Stream<File> -> Stream<String>
	.filter(s-> s.indexOf('.') != -1)           // 문자열 중 '.' 없는 경우 제외 
    .map(s -> s. substring(s.indexOf('.') +1)   // .xxx 확장자명만 -> Stream<String>
    .map(String::toUpperCase)					// 대문자 변환
    .distinct()                                 // 중복 제거
    .forEach(System.out::println)               // 결과출력

 

 

 

 

2. 조회 - peek()

스트림 연산 중간에 값을 확인하고 싶을 때 사용!

 

 fileStream.map(File::getName)                  // Stream<File> -> Stream<String>
          .filter(s -> s.indexOf('.') != -1)    // 확장자 없는 경우 제외
          .peek(s-> System.out.println("fileName = " + s)) // 중간 출력
           .map(s -> s.substring(s.indexOf('.') + 1)) // .xxx 확장자 -> Stream<String>
           .peek(s-> System.out.println("extension = " + s))  // 중간 출력
           .forEach(System.out::println); // 최종연산

 

 

 

3. 기본형 스트림 변환 -  mapToInt(), mapToLong(), mapToDouble()

Stream<T> 타입의 스트림 -> 기본형 스트림으로 변환

 

DoubleStream    mapToDouble( ToDoubleFunction<? super T> mapper)
IntStream       mapToInt( ToIntFunction<? super T> mapper)
LongStream      mapToLong( ToLongFunction<? super T> mapper)


// 예시 학생 총점 구하기
Stream<Integer> studentScoreStream = sudentStream.map(Student::getTotalScore);
IntStream studentScoreStream = studentStream.mapToInt(Student::getTotalScore);

 

3-1. 기본형 스트림 제공 메서드 - sum(), average(), max(), min()

int             sum()       스트림의 모든 요소의 총합
OptionalDouble  average()   sum() / (doulble) count()
OptionalInt     max()       스트림의 최대값
OptionalInt     min()       스트림의 최소값


// 예시
IntStream scoreStream = studentStream.mapToInt(Student::getTotalScore);
long totalScore = scoreStream.sum();  // sum() 메서드는 최종연산 -> 스트림 닫힘
OptionalDouble average = scoreStream.average(); // 에러발생 (스트림 이미 닫힘)
double d = average.getAsDouble(); //OptionalDouble에 저장된 값을 꺼내 d에 저장

 

 

3-2. 기본형 스트림 메서드 - summaryStatistics()

sum()과 average()를 모두 호출할 경우 스트림을 재생성할 필요없이 summaryStatistics() 사용하면 Best!

 

// 예시
IntSummaryStatistics stat = scoreStream.summaryStatistics();
long totalCount = stat.getCount();
long totalScore = stat.getSum();
double avgScore = stat.getAverage();
int minScore = stat.getMin();
int maxScore = stat.getMax();

 

3-3. 기본형 스트림 -> Stream<T>, Stremam<Integer>로 변환 - mapToObj(), boxed()

Stream<U>        mapToObj( IntFunctionM<? extends U> mapper )
Stream<Integer>  boxed()

// 예시
IntStream intStream = new Random().ints(1,46)
Stream<String> lottoStream = intStream.distinct().limit(6).sorted()
                             .mapToObj(i -> i+","); // intStream -> Stream<String>
lottoStream.forEach(System.out::print); // 번호 출력

 

 

* mapToInt() 메서드는 Integer.parseInt()와 Integer.intValue() 랑 자주 사용함

Stream<String>     ->    IntStream 변환할 경우  : mapToInt(Integer::parseInt)
Stream<Integer>   ->    IntStream 변환할 경우  : mapToInt(Integer::intValue)