第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時綁定郵箱和手機立即綁定

正在回答

3 回答

出現(xiàn)了java.io.FileNotFoundException: matrix2 的錯誤

?修改mapper2

@Override

protected void setup(Context context) throws IOException, InterruptedException {

super.setup(context);

//通過輸入流將全局緩存變量中的 右側(cè)矩陣 讀入List<String>中

Configuration conf = context.getConfiguration();

? ? ??

FileSystem fs = FileSystem.get(conf);

FSDataInputStream in = fs.open(new Path("/matrix/step1_output/part-r-00000"));

? ? ? ? //FileReader fr = new FileReader(itermOccurrenceMatrix);

BufferedReader br = new BufferedReader(new InputStreamReader(in));

//每一行的格式是: 行 tab 列_值,列_值,列_值,列_值

String line = null;

while((line = br.readLine())!=null) {

cacheList.add(line);

}

in.close();

br.close();

}


2 回復 有任何疑惑可以回復我~
#1

hyonline_ 提問者

好棒能行!請問這里用的還是分布式緩存的方法嗎?如果不是這兩個方法有什么明顯優(yōu)劣嗎?
2018-05-18 回復 有任何疑惑可以回復我~
#2

陸米 回復 hyonline_ 提問者

這里是map啟動前就讀從hdfs讀一次,如果做了緩存就是從節(jié)點的本地文件系統(tǒng)讀。
2019-01-11 回復 有任何疑惑可以回復我~

tql,就是有點搞不懂為什么原來不行

0 回復 有任何疑惑可以回復我~

能行。

0 回復 有任何疑惑可以回復我~

舉報

0/150
提交
取消
微信客服

購課補貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學習伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號