我以这种方式将文件放入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;
}
但我读到的第一个双精度,总是一个随机的负数!为什么?它是从哪里来的?我读到的其他双打是正确的(它们是我所期望的)
你知道吗?
暂无答案!
目前还没有任何答案,快来回答吧!