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 ``` ## సమాంతర ప్రవాహాలు ```java list.parallelStream().filter(...).collect(...); // process across multiple cores // ⚠️ use only for large data + independent/stateless operations; measure first ``` ## ఇది ఎందుకు ముఖ్యమైనది Stream API Java ఎలా డేటా ప్రక్రియ చేస్తుందో పరిణామం చేసింది — వర్బోస్, ఎర్రర్-ప్రోన్ లూప్‌లను సంక్షిప్త, చదవదగిన, డిక్లరేటివ్ పైప్‌లైన్‌లతో ఫిల్టరింగ్, మ్యాపింగ్, సార్టింగ్, గ్రూపింగ్ మరియు సమ్మిళితం కోసం భర్తీ చేసింది. ఇది ఆధునిక జావాలో డేటా మానిప్యులేషన్ కోసం విస్తృతంగా ఉపయోగించబడుతుంది, కోడ్ యొక్క ఉద్దేశ్యాన్ని స్పష్టంగా చేస్తుంది, మరియు lambdas మరియు మెథడ్ రిఫరెన్సెస్‌తో ఫంక్షనల్ శైలి కోసం ఇంటిగ్రేట్ చేస్తుంది. సోమరి ఇంటర్‌మీడియట్/ఆర్డర్ టర్మినల్ మోడల్, సాధారణ ఆపరేషన్‌లు (filter/map/collect/reduce/groupingBy), మరియు సమాంతర ప్రవాహాల ఎంపిక (వాటి నిర్దేశాలతో) అర్థం చేసుకోవడం idiomatric సాధారణ జావా రాయడం కోసం అవసరమైనది. ప్రవాహాలు రెండూ ఉత్పాదకత బూస్టర్ మరియు నిరంతర ఇంటర్‌వ్యూ విషయం, ప్రస్తుత జావా ఆచరణలతో ప్రవాహతను ప్రతిబింబిస్తుంది.