job.scala

    val job = new Job(getConf())
    job.getConfiguration().setInt("mapred.map.tasks", 1)
    job.setJarByClass(classOf[LogStats])
    job.setJobName("logstats")
    
    job.setMapperClass(classOf[LocMap])
    job.setReducerClass(classOf[CountReduce])
    
    job.setMapOutputKeyClass(classOf[TextTriple])
    job.setMapOutputValueClass(classOf[LongWritable])
    
    job.setOutputKeyClass(classOf[TextTriple])
    job.setOutputValueClass(classOf[LongWritable])
    
    FileInputFormat.setInputPaths(job, new Path(inputPath))
    FileOutputFormat.setOutputPath(job, new Path(outputPath))
    
    val success = job.waitForCompletion(true)
    
    return if (success) 0 else 1