Es scheint IntStream.iteratenur eine leichte bestellte Version für zu sein IntStream.generate. Ist es wahr? Wenn nicht, was ist der
Ich habe Java-Code, der Objekte von bereitstellt items. Es begrenzt sie basierend auf maxNumber: items.stream() .map(this::myMapper) .filter(item -> item != null) .limit(maxNumber) .collect(Collectors.toList()); Es funktioniert richtig, aber die Frage ist: Gibt es eine Möglichkeit, die...
Ich versuche zu verstehen, warum das folgende Java-Programm ein gibt OutOfMemoryError, während das entsprechende Programm ohne .parallel()dies nicht tut. System.out.println(Stream .iterate(1, i -> i+1) .parallel() .flatMap(n -> Stream.iterate(n, i -> i+n))
std::basic_ioshat einen öffentlichen Konstruktor : explicit basic_ios (std::basic_streambuf<CharT,Traits>* sb); IMO, der einzige Grund für eine Klasse, einen öffentlichen Konstruktor zu haben, ist die Verwendung einer eigenständigen Instanz dieser Klasse in einem Programm. Wenn eine Klasse...
Ich habe eine Karte Map<K, V>und mein Ziel ist es, die doppelten Werte zu entfernen und dieselbe Struktur Map<K, V>erneut auszugeben . Falls der doppelte Wert gefunden wird, muss kaus den beiden Schlüsseln ( k1und k1), die diese Werte enthalten, ein Schlüssel ( ) ausgewählt werden. Aus...
Ich möchte a verwenden, Streamum die Verarbeitung eines heterogenen Satzes von remote gespeicherten JSON-Dateien mit unbekannter Anzahl zu parallelisieren (die Anzahl der Dateien ist im Voraus nicht bekannt). Die Dateien können sehr unterschiedlich groß sein, von 1 JSON-Datensatz pro Datei bis zu...
Ich habe versucht, ein int-Array in List zu konvertieren, bin den ungewohnten Weg der Verwendung von Java 8 Stream gegangen und habe mir das ausgedacht Arrays.stream(arr).boxed().collect(Collectors.toList()); Ich habe immer noch Schwierigkeiten, diese Zeile vollständig zu verstehen. Warum wird...
Geschlossen . Diese Frage muss fokussierter sein . Derzeit werden keine Antworten akzeptiert. Möchten Sie diese Frage verbessern? Aktualisieren Sie die Frage so, dass sie sich nur auf ein Problem konzentriert, indem Sie diesen Beitrag bearbeiten . Geschlossen vor 4 Tagen . AtomicInteger...
Zum Bereinigen einer Datenliste habe ich eine Methode erstellt, die die Liste der Daten und die Liste der durchzuführenden Reinigungsvorgänge akzeptiert. public <T> List<T> cleanData(List<T> data, List<Function<T, T>> cleanOps) {
Ich habe eine Liste solcher Farben: Pink, Blau, Rot, Blau, Grau, Grün, Lila, Schwarz ... usw. List<String> listOfColors = Arrays.asList("Pink", "Blue", "Red", "blue", "Grey", "green", "purple", "black"); Es gibt einige Zwischenoperationen wie das Filtern einiger Fruchtfarben. Jetzt...
Ich habe eine Map<String,List<String>>und möchte, dass daraus wird, Map<String,List<Long>>weil jede Stringin der Liste eine darstellt Long: Map<String,List<String>> input = ...; Map<String,List<Long>> output= input.entrySet() .stream()...
Ich habe eine Hash-Map mit den folgenden Werten, in Werten, die ich als String-Datentyp datiert habe. Ich möchte alle Daten vergleichen, die in der Karte verfügbar sind, und nur einen Schlüsselwert extrahieren, der ein sehr aktuelles Datum hat. Ich möchte mit Werten vergleichen, nicht mit...
Ich denke, das ist eine ziemlich einfache Frage. Ich würde es gerne verwenden std::get_time, aber es erfordert eine Art Stream, mit dem ich verwendet werden kann. Ich übergebe die Daten in a string_viewund möchte vermeiden, sie nur zu kopieren, um das Datum zu
Ich habe folgenden Code: Stream<String> lines = reader.lines(); Wenn die erste Zeichenfolge gleich ist, "email"möchte ich die erste Zeichenfolge aus dem Stream entfernen. Für andere Strings aus dem Stream brauche ich diese Prüfung nicht. Wie könnte ich es erreichen? PS Sicher kann ich es...
Ich habe ein Quiz über die Java 8 Stream API der Peek-Methode wie folgt gefunden Arrays.asList("Fred", "Jim", "Sheila") .stream() .peek(System.out::println) .allMatch(s -> s.startsWith("F")); Die Ausgabe ist Fred Jim Ich bin verwirrt, wie dieser Stream funktioniert? Mein erwartetes Ergebnis...
Gibt es eine Möglichkeit, dass das Folgende als ein Satz von Stream-Operationen ausgeführt werden kann, anstatt explizit zu prüfen, ob empfohlene Produkte leer sind, und dann die Standardliste zurückzugeben, andernfalls die gefilterte Liste zurückzugeben ? public List<Product>...
Ich habe eine 35 GB CSVDatei. Ich möchte jede Zeile lesen und die Zeile in eine neue CSV schreiben, wenn sie einer Bedingung entspricht. try (BufferedWriter writer = Files.newBufferedWriter(Paths.get("source.csv"))) { try (BufferedReader br = Files.newBufferedReader(Paths.get("target.csv"))) {...
Ich versuche, den folgenden Code mithilfe von Multithreading auf Auftragsebene zu verarbeiten. List<String> orders = Arrays.asList("order1", "order2", "order3", "order4", "order1"); Aktuelle sequentielle Ausführung: orders.stream().forEach(order -> { rules.forEach(rule -> {...
Ich habe Listvon Employees mit unterschiedlichen Beitrittsdaten. Ich möchte Mitarbeiter vor und nach einem bestimmten Beitrittsdatum von der Liste mithilfe von Streams abrufen. Ich habe versucht, folgenden Code, List<Employee> employeeListAfter = employeeList.stream() .filter(e ->...
Ich versuche, eine Ressource zu filtern und einige Elemente basierend auf einem Feld auszuschließen. Zum Ausschließen habe ich einen Satz (der eine ID enthält, die ausgeschlossen werden muss) und eine Liste (die mehrere Bereiche von IDs enthält, die ausgeschlossen werden müssen). Ich habe die...