Yes...This should do the trick. Warm Regards, Tariq cloudfront.blogspot.com
On Wed, Jun 5, 2013 at 1:38 AM, Niels Basjes <ni...@basjes.nl> wrote: > 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" <chengi.liu...@gmail.com> 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 >> >