Have you tried something like this (i do not have a pc here to check this code)
context.write(NullWritable, new Text(jsn.toString())); On Jun 4, 2013 8:10 PM, "Chengi Liu" <[email protected]> wrote: > Hi, > > I have the following redcuer class > > public static class TokenCounterReducer > extends Reducer<Text, Text, Text, Text> { > public void reduce(Text key, Iterable<Text> values, Context context) > throws IOException, InterruptedException { > > //String[] fields = s.split("\t", -1) > JSONObject jsn = new JSONObject(); > int sum = 0; > for (Text value : values) { > String[] vals = value.toString().split("\t"); > String[] targetNodes = vals[0].toString().split(",",-1); > jsn.put("source",vals[1] ); > jsn.put("target",targetNodes); > //sum += value.get(); > } > // context.write(key, new Text(sum)); > } > } > > I want to save that json to hdfs? > > It was very trivial in hadoop streaming.. but how do i do it in hadoop > java? > Thanks >
