public class WordCount { @ConfigParam private int minCount; @TaskParam(input = "inputPath", output = "outputPath", mapper = WordCountMapper.class, reducer = WordCountReducer.class) public void run() { // ... } public static void main(String[] args) throws Exception { WordCount wc = AnnotationParser.parse(WordCount.class); Configuration conf = new Configuration(); conf.setInt("minCount", wc.minCount); JobConf jobConf = AnnotationParser.parseJob(wc); JobClient.runJob(jobConf); } }