Çfarë është Stream API?

Question

Accepted Answer

**Stream API** (Java 8+) mundëson përpunimin **në stil funksional** të koleksioneve — filtrimin, transformimin dhe agregimin e të dhënave përmes një tubacioni operacionesh, të shprehura deklarativisht (*çfarë* të bëhet) në vend të unazave eksplicite (*si*). ## Stili imperativ 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 ``` Versioni stream shpreh qëllimin qartë si një zinxhir operacionesh, pa unazë manuale ose akumulator. ## Struktura e tubacionit ```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 ``` Operacionet **ndërmjetëse** (filter, map, sorted, distinct) janë **dembel** — ndërtojnë tubacionin por nuk ekzekutohen derisa një operacion **terminal** (collect, forEach, reduce, count) ta shkaktojë atë. ## Operacione të zakonshme ```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 — palosje në një vlerë të vetme ```java int total = nums.stream().reduce(0, (a, b) -> a + b); // sum via reduction ``` ## Rrjedha paralele ```java list.parallelStream().filter(...).collect(...); // process across multiple cores // ⚠️ use only for large data + independent/stateless operations; measure first ``` ## Pse ka rëndësi Stream API transformoi mënyrën se si Java përpunon të dhënat — zëvendësim i unazave të ndërlikuara, të prona ndaj gabimeve me tubacione të koncize, të lexueshme dhe deklarative për filtrimin, hartëzimin, renditjen, grupimin dhe agregimin. Përdoret gjerësisht në Javën moderne për manipulimin e të dhënave, e bën qëllimin e kodit më të qartë dhe integrohet me lambdat dhe referencat e metodave për një stil funksional. Kuptimi i modelit ndërmjetës dembel/terminal i sigurt, operacioneve të zakonshme (filter/map/collect/reduce/groupingBy) dhe opsioni i rrjedhave paralele (me paralajmërimet e tyre) është thelbësor për shkrimin e Jave moderne idiomatike. Rrjedhat janë si një përfitim produktiviteti ashtu edhe një temë e shpeshtë në intervista, që pasqyron rrjedhshmërinë me praktikat aktuale të Jave.