Wie überprüft man den Inhalt des Stream-Objekts ohne Konvertierung in Array in Java 8?

Question

Grundsätzlich muss ich Folgendes tun: 1) Lesen Sie die CSV-Eingabedatei. 2) Filtern Sie die CSV-Daten basierend auf der Blacklist. 3) Sortieren Sie die Eingabe basierend auf den Ländernamen in aufsteigender Reihenfolge. 4) Drucken Sie die Datensätze, die nicht auf der schwarzen Liste stehen. Die CSV-Datei enthält: id, Land-short, Land 1, AU, Australien 2, CN, China 3, AU, Australien 4, CN, China Die schwarze Liste Datei enthält: AU JP Und der gewünschte Ausgang ist 2, CN, China 4, CN, China

import java.io.IOException; 
import java.nio.file.Files; 
import java.nio.file.Paths; 
import java.util.Optional; 
import java.util.stream.Collectors; 
import java.util.stream.Stream; 

public class StreamProcessing { 
    public static void filterCsv(String fileName, String blacklistFile){ 


     try (Stream<String> stream1 = Files.lines(Paths.get(fileName))) { 
      Stream<String> stream2 = Files.lines(Paths.get(blacklistFile)); 
      Optional<String> hasBlackList = stream1.filter(s->s.contains(stream2)).findFirst(); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } 



    public static void main(String args[]) 
    { 
     StreamProcessing sp = new StreamProcessing(); 
     sp.filterCsv("Data.csv","blacklist.txt"); 
    } 
} 

I die Einträge entfernt werden soll, die aus dem Vergleich von dem ersten Strom in der zweiten Strom vorhanden sind, ohne sie in eine Anordnung umzuwandeln?

Answer 1

Sie können einen Stream nur einmal konsumieren. Da Sie Zugriff auf alle Mitglieder der Blacklist benötigen, während Sie jedes Mitglied der Hauptdatei auswerten, müssen Sie zuerst den Blacklist-Stream vollständig konsumieren. Konvertieren Sie aus Effizienzgründen nicht in ein Array, sondern in ein HashSet.

Answer 2

Leider können Sie einen Stream nicht mehr als einmal verwenden, so dass Code, der den Blacklist-Stream für jede Zeile überprüft, fehlschlägt. Die einfachste Lösung wäre, die Blacklist in einer Sammlung zu speichern und dann jede Zeile zu prüfen.

List<String> blacklist = Files.readAllLines(Paths.get(blacklistFile)); 
boolean hasBlacklist = Files.lines(Paths.get(filename)).anyMatch(blacklist::contains);