Załóżmy, że mamy klasę Obj class Obj{ int field; } i że masz listę Objinstancji, tj List<Obj> lst. Teraz, jak mogę znaleźć w Java8 strumieniach sumę wartości pól int fieldz obiektów na liście lstpod kryterium filtrowania (np. Dla obiektu okryterium to o.field > 10)?...
Chciałbym wykonać następujące czynności: List<Integer> list = IntStream.range(0, 7).collect(Collectors.toList()); ale w taki sposób, że wynikowa lista jest implementacją guawy ImmutableList. Wiem, że mógłbym to zrobić List<Integer> list = IntStream.range(0,...
Wyobraź sobie, że mam listę pewnych obiektów: List<Student> Muszę wygenerować kolejną listę zawierającą elementy idsz Studentspowyższej listy: List<Integer> Unikając pętli, czy można to osiągnąć za pomocą kolekcji apache lub guawy ? Które metody powinny być przydatne w moim...
Mam następującą sytuację Map<Key, ListContainer> map; public class ListContainer{ List<AClass> lst; } Muszę scalić wszystkie listy lstz ListContainerobiektów z Mapmapy. public static void main(String args[]){ List<AClass> alltheObjectsAClass = map.values().stream(). //...
Wygląda na to, że mam problem ze zrozumieniem, w jaki sposób Java komponuje operacje strumieniowe do potoku strumieniowego. Podczas wykonywania następującego kodu public static void main(String[] args) { StringBuilder sb = new StringBuilder(); var count = Stream.of(new String[]{"1", "2",...
Wygląda na IntStream.iterateto, że jest to tylko lekka, zamówiona wersja IntStream.generate. Czy to prawda? Jeśli nie, jaka jest podstawowa
Mam trochę kodu Java, który zapewnia obiekty z items. Ogranicza je na podstawie maxNumber: items.stream() .map(this::myMapper) .filter(item -> item != null) .limit(maxNumber) .collect(Collectors.toList()); Działa poprawnie, ale pytanie brzmi: Czy istnieje sposób na ominięcie ograniczenia,...
Próbuję zrozumieć, dlaczego następujący program Java daje OutOfMemoryError, a odpowiedni program bez .parallel(). System.out.println(Stream .iterate(1, i -> i+1) .parallel() .flatMap(n -> Stream.iterate(n, i -> i+n)) .mapToInt(Integer::intValue) .limit(100_000_000) .sum() ); Mam...
Mam mapę Map<K, V>i moim celem jest usunięcie zduplikowanych wartości i Map<K, V>ponowne wygenerowanie tej samej struktury . W przypadku, gdy wartość duplikatów zostanie znaleziony, musi być wybrany jeden klawisz ( k) z dwóch przycisków ( k1i k1), które utrzymują te wartości, z tego...
Chcę użyć Streamdo równoległego przetwarzania heterogenicznego zestawu zdalnie przechowywanych plików JSON o nieznanej liczbie (liczba plików nie jest znana z góry). Rozmiar plików może się znacznie różnić, od 1 rekordu JSON na plik do 100 000 rekordów w niektórych innych plikach. Rekord JSON w tym...
Próbowałem przekonwertować tablicę int na List i wybrałem nieznaną drogę korzystania z Java 8 Stream i wymyśliłem to Arrays.stream(arr).boxed().collect(Collectors.toList()); Nadal mam trudności z pełnym zrozumieniem tej linii, głównie Dlaczego Collectors.toList()w tym przypadku zwraca interfejs...
Do czyszczenia listy danych stworzyłem metodę, która akceptuje listę danych i listę operacji czyszczenia do wykonania. public <T> List<T> cleanData(List<T> data, List<Function<T, T>> cleanOps) { List<T>dataNew=data.stream().map((str) -> { T cleanData =...
Zamknięte . To pytanie musi być bardziej skoncentrowane . Obecnie nie przyjmuje odpowiedzi. Chcesz poprawić to pytanie? Zaktualizuj pytanie, aby skupiało się tylko na jednym problemie, edytując ten post . Zamknięte 3 dni temu . AtomicInteger...
Mam listę takich kolorów: Różowy, niebieski, czerwony, niebieski, szary, zielony, fioletowy, czarny ... itp List<String> listOfColors = Arrays.asList("Pink", "Blue", "Red", "blue", "Grey", "green", "purple", "black"); Istnieje kilka operacji pośrednich, takich jak filtrowanie...
Mam Map<String,List<String>>i chcę, aby się zmieniło, Map<String,List<Long>>ponieważ każdy Stringna liście reprezentuje Long: Map<String,List<String>> input = ...; Map<String,List<Long>> output= input.entrySet() .stream()
Mam mapę skrótu z niższymi wartościami, w wartościach mam datę jako ciąg danych typu. Chciałbym porównać wszystkie daty dostępne na mapie i wyodrębnić tylko jedną kluczową wartość, która ma najnowszą datę. Chciałbym porównać z wartościami, a nie kluczami. Podałem kod poniżej import...
Mam następujący kod: Stream<String> lines = reader.lines(); Jeśli ciąg pięści jest równy "email", chcę usunąć pierwszy ciąg ze strumienia. W przypadku innych ciągów ze strumienia nie potrzebuję tego sprawdzania. Jak mogę to osiągnąć? PS Jasne, że mogę przekształcić go w listę, a...
Znalazłem quiz na temat API Java 8 Stream metody peek, jak poniżej Arrays.asList("Fred", "Jim", "Sheila") .stream() .peek(System.out::println) .allMatch(s -> s.startsWith("F")); Dane wyjściowe to Fred Jim Nie wiem, jak działa ten strumień? Mój oczekiwany wynik powinien...
Czy jest jakiś sposób, aby poniższe czynności można było wykonać jako jeden zestaw operacji strumieniowych, zamiast jawnie sprawdzać, czy zalecane Produkty są puste, a następnie zwracać domyślną listę, inaczej zwracać filtrowaną listę ? public List<Product> getRecommendedProducts() {...
Mam CSVplik 35 GB . Chcę przeczytać każdą linię i napisać linię do nowego pliku CSV, jeśli pasuje do określonego warunku. try (BufferedWriter writer = Files.newBufferedWriter(Paths.get("source.csv"))) { try (BufferedReader br = Files.newBufferedReader(Paths.get("target.csv"))) {...