您可以使用hadoop的outputformat接口来创建自定义格式，这些格式将按照您的意愿写入数据。例如，如果需要将数据写入json对象，则可以执行以下操作：

public class JsonOutputFormat extends TextOutputFormat<Text, IntWritable> {
    @Override
    public RecordWriter<Text, IntWritable> getRecordWriter(
            TaskAttemptContext context) throws IOException, 
                  InterruptedException {
        Configuration conf = context.getConfiguration();
        Path path = getOutputPath(context);
        FileSystem fs = path.getFileSystem(conf);
        FSDataOutputStream out = 
                fs.create(new Path(path,context.getJobName()));
        return new JsonRecordWriter(out);
    }

    private static class JsonRecordWriter extends 
          LineRecordWriter<Text,IntWritable>{
        boolean firstRecord = true;
        @Override
        public synchronized void close(TaskAttemptContext context)
                throws IOException {
            out.writeChar('{');
            super.close(null);
        }

        @Override
        public synchronized void write(Text key, IntWritable value)
                throws IOException {
            if (!firstRecord){
                out.writeChars(",\r\n");
                firstRecord = false;
            }
            out.writeChars("\"" + key.toString() + "\":\""+
                    value.toString()+"\"");
        }

        public JsonRecordWriter(DataOutputStream out) 
                throws IOException{
            super(out);
            out.writeChar('}');
        }
    }
}

如果您不想在输出中包含键，只需发出null，如：

context.write(NullWritable.get(), new IntWritable(sum));

hth公司

如果您只想将json对象的列表写入hdfs而不关心key/value的概念，那么可以使用 NullWritable 在你的 Reducer 输出值：

public static class TokenCounterReducer extends Reducer<Text, Text, Text, NullWritable> {
    public void reduce(Text key, Iterable<Text> values, Context context)
            throws IOException, InterruptedException {
        for (Text value : values) {
            JSONObject jsn = new JSONObject();
            ....
            context.write(new Text(jsn.toString()), null);
        }
    }
}

请注意，您需要更改作业配置以执行以下操作：

job.setOutputValueClass(NullWritable.class);

通过将json对象写入hdfs，我了解到您希望存储json的字符串表示形式，我在上面描述了这一点。如果要将json的二进制表示形式存储到hdfs中，则需要使用 SequenceFile . 显然你可以自己写 Writable 但是我觉得如果你想用一个简单的字符串表示的话，这样更容易。