为了账号安全,请及时绑定邮箱和手机立即绑定

正在回答

3 回答

出现了java.io.FileNotFoundException: matrix2 的错误

 修改mapper2

@Override

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

super.setup(context);

//通过输入流将全局缓存变量中的 右侧矩阵 读入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_ 提问者

好棒能行!请问这里用的还是分布式缓存的方法吗?如果不是这两个方法有什么明显优劣吗?
2018-05-18 回复 有任何疑惑可以回复我~
#2

陆米 回复 hyonline_ 提问者

这里是map启动前就读从hdfs读一次,如果做了缓存就是从节点的本地文件系统读。
2019-01-11 回复 有任何疑惑可以回复我~

tql,就是有点搞不懂为什么原来不行

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

能行。

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

举报

0/150
提交
取消

找不到matrix2

我要回答 关注问题
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号