Kas yra Stream API?

Question

Kas yra Stream API?

Accepted Answer

**Stream API** (Java 8+) leidžia apdoroti kolekcijas **funkcinio stiliaus** būdu — filtruojant, transformuojant ir agreguojant duomenis per operacijų pipeline, išreikštą deklaratyviai (*ką* daryti) o ne su aiškiais ciklais (*kaip*). ## Kodėl tai svarbu ```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 versija aiškiai išreiškia ketinimą kaip operacijų grandinę, be rankinių ciklų ar akumuliatoriaus. ## Pipeline struktūra ```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 ``` **Tarpinės** operacijos (filter, map, sorted, distinct) yra **lentos** — jos sudaro pipeline, bet nevykdomas, kol **galutinė** operacija (collect, forEach, reduce, count) ją suaktyvina. ## Bendros operacijos ```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 — sumažinti į vieną reikšmę ```java int total = nums.stream().reduce(0, (a, b) -> a + b); // sum via reduction ``` ## Lygiagretūs stream-ai ```java list.parallelStream().filter(...).collect(...); // process across multiple cores // ⚠️ use only for large data + independent/stateless operations; measure first ``` ## Kodėl tai svarbu Stream API pakeitė Java duomenų apdorojimo būdą — pakeisdama išdidžius, klaidoms jautrius ciklus glaustais, lengvai skaitomais deklaratyviais pipeline-ais filtravimui, žemėlapyje braižymui, rūšiavimui, grupavimui ir agregavimui. Jis plačiai naudojamas šiuolaikinėje Java duomenų manipuliacijai, padaro kodo ketinimą aiškesnį ir integruojasi su lambda ir metodų nuorodomis funkciniam stiliui pasiekti. Supratimas apie lentos tarpines / greitasias galutines operacijas, bendras operacijas (filter/map/collect/reduce/groupingBy) ir lygiagretūs stream-ai (su jų perspėjimais) yra būtini šiuolaikinei, idiomatinei Java rašyti. Stream-ai yra tiek produktyvumo padidėjimas, tiek dažna pokalbio tema, atspindinti šiuolaikinės Java praktikos žinomumą.