Stream Pipeline Lifecycle: Source -> Intermediate Operations -> Terminal Operation0%

Intermediate Operations: filter(), map(), flatMap(), sorted(), distinct()

Stream Pipeline Lifecycle: Source -> Intermediate Operations -> Terminal Operation

Advanced15 min read•Updated: 2025-01-15

🌊 Stream Pipeline Lifecycle: Source -> Intermediate Operations -> Terminal Operation

Introduction

The Java Stream API (java.util.stream) provides a declarative, functional approach to processing sequences of elements. Unlike collections, a Stream does not store elements in memory; it acts as an on-demand data conveyor belt executing computational pipelines.

🔄 The 3 Phases of Every Stream Pipeline

1┌─────────────────┐       ┌─────────────────────────┐       ┌────────────────────┐
2│  STREAM SOURCE  │ ────► │ INTERMEDIATE OPERATIONS │ ────► │ TERMINAL OPERATION │
3│ (List, Set, IO) │       │ (filter, map, sorted)   │       │ (collect, sum, etc)│
4└─────────────────┘       └─────────────────────────┘       └────────────────────┘
5         ▲                             ▲                               ▲
6         │                             │                               │
7   Provides Data                Transforms Data                  Executes Pipeline
8  (Lazy: No work yet)          (Chained Lazily)                 (Consumes Stream)

💤 Lazy Evaluation: The Core Performance Magic

Intermediate operations are strictly lazy. They perform zero computation until the terminal operation is invoked:

1List<String> names = List.of("Aarav", "Neha", "Rohit", "Pooja");
2 
3// Setting up the pipeline - NO PRINTING HAPPENS HERE!
4Stream<String> pipeline = names.stream()
5    .filter(name -> {
6        System.out.println("Filtering: " + name);
7        return name.length() > 4;
8    });
9 
10System.out.println("--- Stream configured, but not executed yet! ---");
11 
12// Terminal operation triggers execution!
13long count = pipeline.count();
14System.out.println("Result count: " + count);

🚫 Crucial Rule: Streams Cannot Be Reused

A stream is consumed once a terminal operation executes. Attempting to invoke another operation throws an IllegalStateException:

1Stream<String> stream = names.stream();
2stream.forEach(System.out::println); // Terminal operation 1
3 
4// ❌ Throws: java.lang.IllegalStateException: stream has already been operated upon or closed
5// stream.count(); 

Next Lesson

Intermediate Operations: filter(), map(), flatMap(), sorted(), distinct()

Continue learning with hands-on practice, examples, and exercises in the upcoming topic.

Related Lessons

Previous Lesson	Next Lesson
Method References (Class::method, instance::method, Class::new)	Intermediate Operations: filter(), map(), flatMap(), sorted(), distinct()

Practice Quiz

Test your understanding of this lesson with 1 questions. Each question has one correct answer.

Previous Next

PreviousPrevNext

MSK Institute • Shikohabad

Loading Page Content...

Preparing courses, live labs, and learning resources.सामग्री लोड हो रही है, कृपया प्रतीक्षा करें...

Connecting serverPlease wait...

💻 Practical Labs🚀 Free Demo📜 Verified Certificates

Intermediate Operations: filter(), map(), flatMap(), sorted(), distinct()

Stream Pipeline Lifecycle: Source -> Intermediate Operations -> Terminal Operation

Advanced15 min read•Updated: 2025-01-15

Study Materials

🌊 Stream Pipeline Lifecycle: Source -> Intermediate Operations -> Terminal Operation

Introduction

🔄 The 3 Phases of Every Stream Pipeline

1┌─────────────────┐       ┌─────────────────────────┐       ┌────────────────────┐
2│  STREAM SOURCE  │ ────► │ INTERMEDIATE OPERATIONS │ ────► │ TERMINAL OPERATION │
3│ (List, Set, IO) │       │ (filter, map, sorted)   │       │ (collect, sum, etc)│
4└─────────────────┘       └─────────────────────────┘       └────────────────────┘
5         ▲                             ▲                               ▲
6         │                             │                               │
7   Provides Data                Transforms Data                  Executes Pipeline
8  (Lazy: No work yet)          (Chained Lazily)                 (Consumes Stream)

💤 Lazy Evaluation: The Core Performance Magic

Intermediate operations are strictly lazy. They perform zero computation until the terminal operation is invoked:

1List<String> names = List.of("Aarav", "Neha", "Rohit", "Pooja");
2 
3// Setting up the pipeline - NO PRINTING HAPPENS HERE!
4Stream<String> pipeline = names.stream()
5    .filter(name -> {
6        System.out.println("Filtering: " + name);
7        return name.length() > 4;
8    });
9 
10System.out.println("--- Stream configured, but not executed yet! ---");
11 
12// Terminal operation triggers execution!
13long count = pipeline.count();
14System.out.println("Result count: " + count);

🚫 Crucial Rule: Streams Cannot Be Reused

A stream is consumed once a terminal operation executes. Attempting to invoke another operation throws an IllegalStateException:

1Stream<String> stream = names.stream();
2stream.forEach(System.out::println); // Terminal operation 1
3 
4// ❌ Throws: java.lang.IllegalStateException: stream has already been operated upon or closed
5// stream.count(); 

Next Lesson

Intermediate Operations: filter(), map(), flatMap(), sorted(), distinct()

Continue learning with hands-on practice, examples, and exercises in the upcoming topic.

Related Lessons

Previous Lesson	Next Lesson
Method References (Class::method, instance::method, Class::new)	Intermediate Operations: filter(), map(), flatMap(), sorted(), distinct()

Practice Quiz

Test your understanding of this lesson with 1 questions. Each question has one correct answer.

Previous Next