2017-04-14 2 views
0

Zeppelinでは別の段落で作成したデータフレームを使用しています。私は自分のdf変数のタイプを表示し、取得します:Sparkデータフレームメソッドにアクセスできない

res35: String = DataFrame 

これはデータフレームであることを示しています。しかし、df変数でselectを使用しようとするとエラーが発生します。

<console>:62: error: value select is not a member of Object 

ObjectをDataframeなどに変換する必要はありますか?誰かが私に行方不明を教えてもらえますか? TIA!

私のコードは次のとおりです。

val df = z.get("wds")       
df.getClass.getSimpleName 
df.select(explode($"filtered").as("value")).groupBy("value").count.show 

これはfolowwingを与える(編集済み)出力:

df: Object = [racist: boolean, contributors: 
string, coordinates: string, ...n: Int = 20 
    res35: String = DataFrame 
    <console>:62: error: value select is not a member of Object 
        df.select(explode($"filtered").as("value")).groupBy("value").count.show 

答えて

0

は私が

.asInstanceOf[DataFrame] 

すなわち

import org.apache.spark.sql.DataFrame 
val df = z.get("wds").asInstanceOf[DataFrame] 
を行方不明になったようです3210
関連する問題