如何在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 试试看
Global site tag (gtag.js) - Google Analytics