Suchergebnisse für Anfrage "spark-streaming"
Das dynamische Lesen von Dateien aus HDFS in Funkentransformationsfunktionen
Wie kann eine Datei aus HDFS in einer Spark-Funktion gelesen werden, die sparkContext nicht innerhalb der Funktion verwendet? Beispiel val filedata_rdd = rdd.map { x => ReadFromHDFS(x.getFilePath) }Frage: Wie kann ReadFromHDFS implementiert ...