Τι είναι το Stream API;

Question

Accepted Answer

Το **Stream API** (Java 8+) ενεργοποιεί την επεξεργασία συλλογών **σε συναρτησιακό στυλ** — φιλτράρισμα, μετασχηματισμό και συγκέντρωση δεδομένων μέσω ενός αγωγού λειτουργιών, εκφρασμένο δηλωτικά (*τι* να κάνετε) και όχι με ρητούς βρόχους (*πώς*). ## Αναγκαστικό στυλ vs Stream ```java // ❌ imperative — explicit loop, mutable accumulator List result = new ArrayList<>(); for (Person p : people) { if (p.getAge() >= 18) { result.add(p.getName().toUpperCase()); } } // ✅ stream — declarative pipeline, reads like a description of the transformation List result = people.stream() .filter(p -> p.getAge() >= 18) // keep adults .map(p -> p.getName().toUpperCase()) // extract + transform names .collect(Collectors.toList()); // gather into a list ``` Η έκδοση stream εκφράζει τη πρόθεση με σαφήνεια ως αλυσίδα λειτουργιών, χωρίς χειροκίνητο βρόχο ή συσσωρευτή. ## Δομή αγωγού ```text Source → Intermediate operations (lazy) → Terminal operation (triggers execution) ``` ```java stream() // source .filter(...) .map(...) // intermediate — lazy, return a new stream, chainable .collect(...) // terminal — produces a result, RUNS the pipeline ``` Οι **ενδιάμεσες** λειτουργίες (filter, map, sorted, distinct) είναι **τεμπέλιδες** — κατασκευάζουν τον αγωγό αλλά δεν εκτελούνται έως ότου μια **τελική** λειτουργία (collect, forEach, reduce, count) την ενεργοποιήσει. ## Κοινές λειτουργίες ```java list.stream() .filter(x -> x > 0) // keep matching .map(x -> x * 2) // transform each .sorted() // sort .distinct() // remove duplicates .limit(10) // take first 10 .collect(Collectors.toList()); // aggregations int sum = nums.stream().mapToInt(Integer::intValue).sum(); long count = list.stream().filter(...).count(); Optional first = people.stream().filter(...).findFirst(); boolean any = list.stream().anyMatch(x -> x > 100); // grouping (very powerful) Map> byCity = people.stream().collect(Collectors.groupingBy(Person::getCity)); ``` ## reduce — διπλώστε σε μια μόνο τιμή ```java int total = nums.stream().reduce(0, (a, b) -> a + b); // sum via reduction ``` ## Παράλληλα streams ```java list.parallelStream().filter(...).collect(...); // process across multiple cores // ⚠️ use only for large data + independent/stateless operations; measure first ``` ## Γιατί έχει σημασία Το Stream API μεταμόρφωσε τον τρόπο που η Java επεξεργάζεται δεδομένα — αντικαθιστά τους φλύαρους, επιρρεπείς σε σφάλματα βρόχους με συνοπτικούς, ευαναγνώστους, δηλωτικούς αγωγούς για φιλτράρισμα, απεικόνιση, ταξινόμηση, ομαδοποίηση και συγκέντρωση. Χρησιμοποιείται εκτεταμένα στη σύγχρονη Java για χειρισμό δεδομένων, καθιστά την πρόθεση του κώδικα σαφέστερη και ενσωματώνεται με lambdas και αναφορές μεθόδων για ένα συναρτησιακό στυλ. Η κατανόηση του τεμπέλικου ενδιάμεσου / πρόθυμου τελικού μοντέλου, των κοινών λειτουργιών (filter/map/collect/reduce/groupingBy) και της επιλογής παράλληλων streams (με τις προειδοποιήσεις τους) είναι απαραίτητη για τη σύνταξη ιδιωματικής σύγχρονης Java. Οι streams είναι τόσο ένα αύξηση της παραγωγικότητας όσο και ένα συχνό θέμα συνέντευξης, που αντανακλά την ευχέρεια με τις τρέχουσες πρακτικές Java.