Wie lese ich mehrere Zeilenelemente in Spark?
Wenn Sie eine Datei in Spark mit @ les sc.textfile gibt es Ihnen Elemente, wobei jedes Element eine separate Zeile ist. Ich möchte jedoch, dass jedes Element aus N Zeilen besteht. Ich kann auch keine Trennzeichen verwenden, da diese Datei keine enthält. Wie kann ich einen Funken erzeugen, der mir mehrere Linienelemente gibt?
Und ich bin daran interessiert, das @ zu benutz NLineInputFormat Klasse. Ist das in Spark möglich? Ich kann Beispiele dafür für MapReduce sehen, aber ich habe keine Ahnung, wie sich das in Spark auswirken würde.