Ce este Stream API?

Question

Ce este Stream API?

Accepted Answer

**Stream API** (Java 8+) permite procesarea **în stil funcțional** a colecțiilor — filtrarea, transformarea și agregarea datelor printr-un pipeline de operații, exprimate declarativ (*ce* să faci) mai degrabă decât cu bucle explicite (*cum*). ## Imperativ vs stil 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 ``` Versiunea stream exprimă intenția clar ca un lanț de operații, fără buclă manuală sau acumulator. ## Structura pipeline-ului ```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 ``` Operațiile **intermediate** (filter, map, sorted, distinct) sunt **lazy** — construiesc pipeline-ul dar nu se execută până când o operație **terminal** (collect, forEach, reduce, count) o declanșează. ## Operații comune ```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 — pliere la o singură valoare ```java int total = nums.stream().reduce(0, (a, b) -> a + b); // sum via reduction ``` ## Streamuri paralele ```java list.parallelStream().filter(...).collect(...); // process across multiple cores // ⚠️ use only for large data + independent/stateless operations; measure first ``` ## De ce conteaza Stream API a transformat cum Java procesează date — înlocuind bucle verbose și predispuse la erori cu pipeline-uri concise, ușor de citit, declarative pentru filtrare, mapare, sortare, grupare și agregare. Este folosit intens în Java modern pentru manipularea datelor, face intenția codului mai clară și se integrează cu lambda-uri și referințe de metode pentru un stil funcțional. Înțelegerea modelului lazy intermediate / eager terminal, operațiile comune (filter/map/collect/reduce/groupingBy) și opțiunea streamurilor paralele (cu rezervele lor) este esențială pentru scrierea idiomatic a Java-ului modern. Streamurile sunt atât un impuls de productivitate, cât și un subiect frecvent de interviu, reflectând fluența cu practicile actuale ale Java.