如何在dfs中创建一个SequenceFile
peng5047
2011-05-06
大家好,我想创建一个SequenceFile,遇到了些问题,我的程序:
Configuration conf = new Configuration(); FileSystem fs = FileSystem.get(URI.create("/findmax/sequence.seq"), conf);//findmax是我dfs里的一个目录 Path name = new Path("/findmax/sequence.seq"); IntWritable key = new IntWritable(); Text value = new Text(); SequenceFile.Writer sw = SequenceFile.createWriter(fs, conf, name, key.getClass(),value.getClass());运行后提示:Mkdirs failed to create /findmax,请问正确的写法应该是什么样的呢? |
|
dikar
2011-05-06
/findmax/sequence.seq 修改为 sequence.seq 试试看
|