org.terrier.utility.io
Class HadoopPlugin.JobFactory

java.lang.Object
  org.terrier.utility.io.HadoopPlugin.JobFactory

Enclosing class:

HadoopPlugin

public abstract static class HadoopPlugin.JobFactory
extends Object

a Job Factory is responsible for creating Terrier MapReduce jobs. This should be used when requesting a Terrier MapReduce job, as it adequately initialises the job, such that Terrier can run correctly.

Constructor Summary

HadoopPlugin.JobFactory()

Method Summary

abstract void	close() Finish with this job factory.
protected static void	makeTerrierJob(org.apache.hadoop.mapred.JobConf jc) Add additional informatino to a MapReduce job about the Terrier configuration
abstract org.apache.hadoop.mapred.JobConf	newJob() Make a new job

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HadoopPlugin.JobFactory

public HadoopPlugin.JobFactory()

Method Detail

newJob

public abstract org.apache.hadoop.mapred.JobConf newJob()
                                                 throws Exception

Make a new job

Throws:

Exception

makeTerrierJob

protected static void makeTerrierJob(org.apache.hadoop.mapred.JobConf jc)
                              throws IOException

Add additional informatino to a MapReduce job about the Terrier configuration

Throws:

IOException

close

public abstract void close()

Finish with this job factory. If the JobFactory was created using HOD, then the HOD job will also be ended