Stream API(2)

Stream API 를 활용한 데이터 컬렉션 처리란 뭘까?

컬렉션(자료구조) 내의 데이터를 원하는 형태로 변환하거나, 필요 없는 데이터를 걸러내고, 특정 방식으로 계산하는 작업을 뜻합니다.

• 필터링: 조건에 맞지 않는 데이터를 걸러내는 작업. (예: 나이가 18살 이상인 사람만 필터링)
• 정렬: 데이터를 오름차순 또는 내림차순으로 정렬하는 작업. (예: 성적 순으로 학생을 정렬)
• 변환: 데이터를 다른 형태로 바꾸는 작업. (예: 섭씨 온도를 화씨로 변환)
• 집계: 데이터를 하나의 값으로 축소하는 작업. (예: 모든 상품의 총합 계산)

 

시나리오 코드 1 - 자료구조 내의 데이터를 필터링 해보기
18세 이상의 학생들만 필터링하고, 그 결과를 List로 수집하는 작업을 해보자.

중간 연산 - filter 사용
최종 연산 - collect


사전 기반 지식
Collectors는 자바 8에서 제공하는 유틸리티 클래스로, collect() 메서드와 함께 사용됩니다.

public class StreamFilterTest1 {

	public static void main(String[] args) {
		  // 샘플 데이터 준비
        List<Integer> ages = Arrays.asList(20, 11, 18, 24, 33, 40, 2);
        
        // 나이가 18 이상인 학생만 필터링 후 List로 수집
        List<Integer> adultAges = ages.stream()
                                      .filter(age -> age >= 18) // 중간 연산: 나이 18 이상 필터링
                                      .collect(Collectors.toList()); // 최종 연산: 결과를 List로 수집
        
        System.out.println(adultAges); // 출력: [20, 18, 24, 33, 40]

	}

}

실행 결과___

Collectors.toSet() : Collectors.toSet()은 스트림의 데이터를 Set 으로 수집합니다

Collectors.toMap() : 스트림의 데이터를 Map 으로 수집할 때 사용됩니다.

• toMap()은 두 가지 정보를 필요(Key 값을 어떻게 지정할지, Value 값을 어떻게 지정할지)

 

시나리오 코드 2 - 자료구조 내의 데이터를 변환 해보기

제품의 가격을 리스트로 저장한 뒤, 스트림을 활용해서 모든 제품의 가격에 10% 세일을 적용해 새로운 리스트를 생성해 보자.


중간 연산 - map 사용
최종 연산 - collect , forEach

public class StreamMapTest2 {

	public static void main(String[] args) {
		List<Double> prices = Arrays.asList(100.0, 200.0, 300.0);

		// 10% 세일 적용된 가격으로 변환하고 List로 수집
		List<Double> discountedPrices = prices.stream()
				.map(price -> price * 0.9) // 모든 가격에 10% 할인  (.map -> 변환)
				.collect(Collectors.toList());

		// 할인된 가격 출력 (자료구조의 스트림을 사용한 최종연산 사용 코드)
		discountedPrices.forEach(e -> System.out.println("할인 가격 : " + e)); // 출력: 90.0, 180.0, 270.0

	}

}

실행 결과____

 

시나리오 코드 3 - 자료구조 내의 데이터를 집계 해보기
정수 리스트에서 값을 합산하여 총합을 계산을 집계해 보자.


최종 연산 - reduce
.reduce(초기값, 람다식)에 형태 입니다.

주의 : reduce는 스트림의 요소들을 하나로 결합하여 단일 결과값을 생성합니다. 이 과정에서 스트림의 모든 데이터를 처리하므로, 이후에 추가적인 연산이 불가능합니다. 즉, 스트림을 종료하는 연산입니다.

public class StreamReduceTest3 {

	public static void main(String[] args) {
		
		List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

		// 리스트의 숫자들을 모두 더함
		int sum = numbers.stream()
						 .reduce(0, (a, b) -> a + b); // 스트림의 요소들을 하나로 결합
		System.out.println(sum); // 출력: 15

	}

}

실행 결과____

 

시나리오 코드 4 - 자료구조 내의 데이터를 정렬 해보기
정수 리스트를 오름차순으로 정렬하여 출력해 보자.

최종 연산 - stored();

public class StreamStoredTest4 {

	public static void main(String[] args) {
		
		List<Integer> numbers = Arrays.asList(5, 3, 1, 4, 2);

		// 리스트의 숫자들을 오름차순으로 정렬
		List<Integer> sortedNumbers1 = numbers.stream().sorted() // 오름차순 정렬
				.collect(Collectors.toList());

		// 내림차순 정렬
		List<Integer> sortedNumbers2 = numbers.stream().sorted(Comparator.reverseOrder()) // 내림차순 정렬
				.collect(Collectors.toList());

		System.out.println(sortedNumbers1); // 출력: [1, 2, 3, 4, 5]
		System.out.println("------------");
		System.out.println(sortedNumbers2); // 출력: [5, 4, 3, 2, 1]

	}

}

실행 결과____