E.g.
public class WordCount { public static void main(String[] args) throws Exception { JobConf conf = new JobConf(WordCount.class); conf.setOutputKeyClass(Text.class); conf.setOutputValueClass(Text.class); conf.setOutputFormat(CustomMultipleTextOutputFormat.class); FileInputFormat.setInputPaths(conf, new Path(args[0])); FileOutputFormat.setOutputPath(conf, new Path(args[1])); JobClient.runJob(conf); }}class CustomMultipleTextOutputFormat extends MultipleTextOutputFormat<Object, Object> { protected String generateFileNameForKeyValue(Object key, Object value, String name) { return key.toString() + "-" + name; }} |
No comments:
Post a Comment
Note: Only a member of this blog may post a comment.