@Override
public void configure(JobConf job) {
l = job.getInt(MinHashLshDriver.L_PROPERTY, MinHashLshDriver.L_VALUE);
try {
Path[] localFiles = DistributedCache.getLocalCacheFiles(job);
// System.out.println("local:" + localFiles[0].getName());
// FileSystem fs = localFiles[0].getFileSystem(job);
FileSystem fs = FileSystem.get(job);
// Reader reader = new SequenceFile.Reader(fs, localFiles[0], job);
Reader reader = new SequenceFile.Reader(fs, new Path("lshfile"), job);
reader.next(lsh);
reader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
LshMapper.java 文件源码
java
阅读 16
收藏 0
点赞 0
评论 0
项目:pss
作者:
评论列表
文章目录