私はいくつかの基本的なデータ型を試して、
val x = Vector("John Smith", 10, "Illinois")
val x = Seq("John Smith", 10, "Illinois")
val x = Array("John Smith", 10, "Illinois")
val x = ...
val x = Seq( Vector("John Smith",10,"Illinois"), Vector("Foo",2,"Bar"))
toDF()
しかし、その後も誰も申し出ませんimport spark.implicits._
。
私の目的は、sometingを次のように使用することですx.toDF("name","age","city").show
最後の例ではtoDF
が存在しますが、エラー"java.lang.ClassNotFoundException" .
ノート:
Spark v2.2 で Spark-shell を使用しています。
create Vector のような複雑なソリューションではなく
toDF(names)
、 でパラメータ化された列名に基づく一般的な変換が必要です。case class Person(name: String, age: Long, city: String)
toDF後のショーの期待される結果は
+----------+---+--------+
| name|age| city|
+----------+---+--------+
|John Smith| 10|Illinois|
+----------+---+--------+