So speichern Sie die Ausgabe, die Iterable [String] zu hdfs in Spark-Scala ist. Iterable [Zeichenfolge]So speichern Sie Iterable [String] zu hdfs in Spark-Scala
Hinweis: ouput ist kein RDD (Ich kann nicht output.saveAsTextFile verwenden („hdfs-Pfad“)
Eine Möglichkeit ist, nur eine einfache HDFS-Datei (die gleiche Art und Weise schreiben Sie tun würden, in Vanille Scala oder Java). Das hat nichts mit Funken zu tun.
ein anderer Weg ist Ihr output zu einer RDD konvertieren und speichern.
val output = countOrdersStatus.map(input => input._1 + "\t" + input._2)
sc.makeRDD(output.toList).saveAsTextFile("hdfs-path")
Der obige Code funktioniert sehr gut. Danke. – Anhata