JAVA 스트림 중간 연산과 최종 연산 완전 정복

🔗 스트림 연산이란 무엇인가요?

자바에서 스트림(Stream)은 데이터를 처리하기 위한 새로운 방식으로, 선언적이고 함수형 스타일로 코드를 작성할 수 있게 도와줍니다.
특히 데이터를 필터링하거나 변환하고 집계하는 과정을 일련의 연산으로 구성하는데, 이 연산들은 중간 연산과 최종 연산으로 나뉘게 됩니다.

스트림 연산은 데이터를 흐름처럼 다루면서 파이프라인 방식으로 처리하는 것이 특징입니다.
즉, 여러 연산을 체인 형태로 연결하여 중간에 데이터를 변형하거나 걸러낸 뒤, 마지막에 결과를 수집하거나 출력하게 되죠.
중간 연산은 여러 개를 연결할 수 있으며, 최종 연산은 딱 한 번만 사용할 수 있다는 점도 기억해두면 좋습니다.

💬 스트림은 단일 방향의 데이터 흐름을 따라 filter → map → sorted → collect 등 연산을 체계적으로 구성할 수 있습니다.

스트림 연산 구조의 핵심은 지연 평가(lazy evaluation)입니다.
중간 연산은 실행만 정의해두고, 최종 연산이 호출될 때 비로소 전체 파이프라인이 실행되며 결과가 반환됩니다.
즉, 중간 연산만 연결한 상태에서는 아무 일도 일어나지 않고, 실제 데이터 처리와 반환은 마지막 연산에서 이루어지는 구조라는 것이죠.

이런 구조는 성능 측면에서도 장점이 큽니다.
불필요한 데이터 처리나 메모리 사용을 줄일 수 있고, 필요한 순간에만 연산을 수행하기 때문에 효율적인 데이터 흐름이 가능해지는 것입니다.
바로 이런 점이 스트림이 현대 자바 개발에서 널리 사용되는 이유이기도 합니다.

🛠️ 중간 연산의 종류와 특징

중간 연산(Intermediate Operation)은 스트림에서 데이터를 가공하거나 필터링하는 역할을 합니다.
이 연산들은 최종 연산이 실행되기 전까지는 실제로 동작하지 않고 대기 상태에 있으며, 연속적으로 연결될 수 있다는 특징이 있습니다.

대표적인 중간 연산에는 다음과 같은 것들이 있습니다.

• 🔍filter() – 조건에 맞는 요소만 필터링
• 🧩map() – 요소를 변환하여 새로운 스트림 생성
• 🔢sorted() – 스트림 내 요소 정렬
• 🎯distinct() – 중복 제거
• 📌limit(), skip() – 특정 개수만큼 자르거나 건너뜀

중간 연산은 반환형이 스트림(Stream)이기 때문에 체이닝 방식으로 여러 개를 연달아 연결할 수 있습니다.
예를 들어, filter → map → sorted와 같이 조합하여 복잡한 데이터 가공도 매우 간결하게 처리할 수 있죠.

그리고 중요한 점은 중간 연산만으로는 결과를 얻을 수 없다는 것입니다.
이 연산들은 모두 lazy하게 동작하기 때문에, 반드시 최종 연산과 함께 사용해야만 실제로 실행됩니다.
이 개념은 다음 STEP에서 좀 더 자세히 설명드릴게요.

⚙️ 최종 연산의 역할과 예시

최종 연산(Terminal Operation)은 스트림 처리 과정의 마지막 단계로, 중간 연산을 통해 구성된 연산 체인을 실제로 실행합니다.
즉, 최종 연산이 호출되어야만 그 이전에 선언된 중간 연산들이 동작하게 되는 것이죠.

최종 연산은 결과를 반환하거나 콘솔에 출력하는 등 명확한 작업을 수행하며, 한 번 수행되면 해당 스트림은 더 이상 사용할 수 없습니다.

대표적인 최종 연산은 다음과 같습니다.

• 🖨️forEach() – 각 요소를 반복하며 작업 수행
• 📥collect() – 요소를 리스트, 집합 등으로 수집
• 🔢count() – 요소 개수 반환
• ➕reduce() – 누적하여 단일 결과 도출
• ✔️anyMatch(), allMatch() – 조건 만족 여부 검사

예를 들어 중간 연산으로 filter와 map을 사용했다 하더라도, collect()나 forEach()가 호출되지 않으면 그 이전 연산들은 실제로 실행되지 않습니다.
바로 이 점이 스트림의 효율성과 유연성을 극대화하는 요소 중 하나입니다.

List<String> data = Arrays.asList("apple", "banana", "cherry");

List<String> result = data.stream()
    .filter(s -> s.length() > 5)
    .map(String::toUpperCase)
    .collect(Collectors.toList());

System.out.println(result); // 출력: [BANANA, CHERRY]

이처럼 collect()를 통해 리스트로 결과를 수집하는 순간, 앞서 정의한 filter와 map이 순차적으로 실행되며 최종 결과가 만들어집니다.
이것이 스트림에서 최종 연산이 가지는 중요한 역할입니다.

🔌 왜 최종 연산 전까진 실행되지 않을까?

스트림(Stream)의 핵심 개념 중 하나는 지연 평가(Lazy Evaluation)입니다.
이는 중간 연산이 즉시 실행되는 것이 아니라, 최종 연산이 호출될 때까지 실행을 보류한다는 의미입니다.
이 덕분에 스트림은 매우 효율적인 연산이 가능하죠.

중간 연산들은 모두 “어떤 연산을 할지” 정의만 해놓고, 실제 데이터 처리 로직은 최종 연산이 호출되는 순간부터 시작됩니다.
이러한 구조는 불필요한 계산을 줄이고 성능을 개선하는 데 큰 도움이 됩니다.

💬 스트림은 파이프라인 전체를 구성해두고, 최종 연산 시점에서 필요한 만큼만 계산을 수행합니다.

예를 들어, 리스트에서 짝수만 골라 두 배로 만든 뒤, 첫 번째 값만 가져오고 싶다면 실제로 모든 데이터를 처리할 필요는 없습니다.
최종 연산인 findFirst()가 호출될 때, 조건을 만족하는 첫 번째 요소까지만 처리하면 되죠.

Optional<Integer> result = Stream.of(1, 2, 3, 4, 5)
    .filter(n -> n % 2 == 0)
    .map(n -> n * 2)
    .findFirst(); // 출력: Optional[4]

위 예제에서는 실제로 2까지만 평가되고 그 이후 요소들은 평가되지 않습니다.
이처럼 스트림은 필요한 만큼만 계산하기 때문에 성능 최적화에 탁월합니다.

단, 이러한 구조를 잘못 이해하고 불필요한 중간 연산을 남발하거나, 최종 연산 없이 결과를 얻으려고 하면 예상과 다른 결과가 나올 수 있습니다.
항상 최종 연산이 실행 시점을 결정한다는 점을 기억하세요.

💡 중간 연산과 최종 연산 실전 예제

중간 연산과 최종 연산의 구조를 실제 코드로 확인하면 개념이 훨씬 쉽게 와닿습니다.
이번에는 간단한 데이터를 가지고 스트림의 전체 흐름을 예제로 살펴보겠습니다.

📘 예제: 필터링 + 변환 + 수집

다음 코드는 문자열 리스트에서 길이가 5 이상인 문자열만 골라 대문자로 변환한 후 리스트로 수집하는 스트림 예제입니다.

List<String> words = Arrays.asList("apple", "kiwi", "banana", "grape");

List<String> result = words.stream()
    .filter(w -> w.length() >= 5)  // 중간 연산 1
    .map(String::toUpperCase)      // 중간 연산 2
    .collect(Collectors.toList()); // 최종 연산

System.out.println(result); // 출력: [APPLE, BANANA, GRAPE]

위 코드에서 filter와 map은 중간 연산이며, 이들은 실제로 collect가 실행되기 전까지 동작하지 않습니다.
최종 연산인 collect()가 호출되는 순간, 모든 연산이 순차적으로 실행되며 결과가 만들어지는 구조입니다.

이런 패턴을 익히고 나면 스트림을 이용한 코드 작성이 훨씬 더 직관적이고 효율적으로 느껴질 것입니다.
반복문보다 코드가 간결해지고, 가독성도 높아지며, 유지보수도 쉬워지니까요.

❓ 자주 묻는 질문 (FAQ)