hadoop:从分布式缓存读取文件

czq61nw1  于 2021-06-04  发布在  Hadoop
关注(0)|答案(0)|浏览(307)

我以这种方式将文件放入distributedcache:

DistributedCache.addCacheFile(new URI(pathU.toString()),job2.getConfiguration());

在我的Map器中,在setup()函数中,我是这样读的:

localFiles = DistributedCache.getLocalCacheFiles(conf);
FileInputStream fis = new FileInputStream(localFiles[0].toString());
DataInputStream dis = new DataInputStream(fis);

for (int i = 0; i < uMat.getMatrix().length; i++) {
   double d = dis.readDouble();
   uMat.getMatrix()[i] = d;
 }

但我读到的第一个双精度,总是一个随机的负数!为什么?它是从哪里来的?我读到的其他双打是正确的(它们是我所期望的)
你知道吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题