Spark konvertiert ein Dataset zu RDD

Question

Ich habe ein Dataset [String] und muss zu einem RDD [String] konvertieren. Wie?

Hinweis: Ich habe vor kurzem von Spark 1.6 zu Spark 2.0 migriert. Einige meiner Kunden erwarteten RDD, aber Spark gibt mir Dataset.

Answer 1

Wie in der scala angegeben API documentation Sie .rdd auf Ihrem Datensatz aufrufen können:

val myRdd : RDD[String] = ds.rdd