public static void RunPreProcessingJob(Configuration conf, String input,
			String output) throws IOException, InterruptedException,
			ClassNotFoundException {

		Job job = new Job(conf, "CourseProject");
		job.setJarByClass(PreProcessing.class);
		job.setMapperClass(ProcessingMapper.class);

		job.setMapOutputKeyClass(ProcessingIntermediumKey.class);
		job.setMapOutputValueClass(DoubleWritable.class);
		job.setSortComparatorClass(KeyComparator.class);
		job.setGroupingComparatorClass(GroupComparator.class);
		job.setReducerClass(ProcessingReducer.class);
		job.setOutputKeyClass(Text.class);
		job.setOutputValueClass(NullWritable.class);

		job.setNumReduceTasks(10);

		FileInputFormat.addInputPath(job, new Path(input));
		FileOutputFormat.setOutputPath(job, new Path(output));
		if (job.waitForCompletion(true)) {
		} else
			System.exit(1);
	}