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.

Antworten auf die Frage(2)

Ihre Antwort auf die Frage