2016-11-02 18 views
1

私はSpark 1.5.0を使用していますが、私のrddからデータフレームを作成する際に問題があります。ここjava.lang.UnsupportedOperationException:タイプMyClassのスキーマはサポートされていません

コードである:

スレッドの例外は、 "メイン" java.lang.UnsupportedOperationExceptionが:型MyClassのため スキーマが

がサポートされていない。ここで

case class MyC (myclass: MyClass) 

    val df = rdd.map {t => MyC(t)}.toDF("cust") 
    df.show() 

はエラーメッセージであります

これに関するお手伝いをさせていただきます。

答えて

0

スパークはリフレクションを使用してデータフレームスキーマを推論しますが、任意のクラスでリフレクションを使用することはできません。私はSparkの文書よりも良い答えを述べることができるかどうか分かりません。there's a section dedicated to exactly this

具体的には、問題は、Sparkがスキーマを推測できる種類が限られていることです。配列、文字列、配列/配列はすべて(これらの型の要素を含む大文字と小文字のクラス)がサポートされていますが、任意のクラスMyClassはサポートされていません。

関連する問題