2017-03-17 7 views
-1

これは私の火花シェルのpwdのApacheSparkでデータを読み取る方法、ディレクトリへのパス?

/home/milenko/spark-2.0.1-bin-hadoop2.7/bin 

であり、これは私が私の火花シェル

scala> val wikiRdd = sc.parallelize(/home/milenko/dom1/wikipedia/src/main/scala/wikipedia/WikipediaARticle) 
<console>:25: error: not found: value/
Error occurred in an application involving default arguments. 
     val wikiRdd = sc.parallelize(/home/milenko/dom1/wikipedia/src/main/scala/wikipedia/WikipediaARticle) 
            ^
<console>:25: error: not found: value/
Error occurred in an application involving default arguments. 
     val wikiRdd = sc.parallelize(/home/milenko/dom1/wikipedia/src/main/scala/wikipedia/WikipediaARticle) 

からしようとした場合、私のデータは

/home/milenko/dom1/wikipedia/src/main/scala/wikipedia 

を置かれているフォルダのPWDです適切なパスを設定するには?

答えて

1

ファイルを読み取るには、このような方法を試してください。パスを二重引用符で囲む "

val input = sc.textFile("/tmp/filename") 
関連する問題