最贊回答 / 貝加爾湖畔v
c1和c2不是代表只有兩個partition,可以把這兩個當做輸入的參數,類似于reduce函數。c1代表前幾個partition已經累計計算到的值,c2代表新partition的值。
2018-03-11
最新回答 / qq_蛻變_33
不用吧,直接用“”把文件路徑括起來就好了,像這樣val rdd = sc.textFile("C:\\Users\\Desktop\\Test.txt")
2017-12-12
最贊回答 / Leco
內個需要自己添加 ...? ?也可以不使用SBT添加依賴jar,打開你spark安裝目錄下/spark-2.1.1/jars檢索spark-core.jar這個名字就會找到對應的jar包將這個jar包導入到工程里就可以了?
2017-09-30
最新回答 / mickeychen
用textFile加載本地文件時你試試這樣寫sc.textFile("/home/hadoop/2.txt")路徑前面就別加 " file:// " 試試,我寫的時候就沒加,可以讀取到本地文件
2017-08-29