edu.stolaf.cs.wmrserver
Class HadoopEngine

java.lang.Object
  edu.stolaf.cs.wmrserver.HadoopEngine

All Implemented Interfaces:

JobEngine

public class HadoopEngine
extends java.lang.Object
implements JobEngine

Field Summary

static java.lang.String	CONF_LANGUAGE A JobConf key which will specify the language the job was written in.
static java.lang.String	CONF_MAPPER
static java.lang.String	CONF_NUMERIC
static java.lang.String	CONF_REDUCER
static java.lang.String	CONF_USER A JobConf key which will specify the job's originating user

Constructor Summary

HadoopEngine(org.apache.hadoop.conf.Configuration conf)

Method Summary

JobInfo	getInfo(Submission submission, org.apache.hadoop.mapred.RunningJob job, org.apache.hadoop.mapred.JobConf conf)
JobStatus	getStatus(Submission submission)
void	kill(Submission submission)
void	submit(JobRequest request, long submissionID, java.io.File mapperFile, java.io.File reducerFile, java.io.File packageDir, org.apache.hadoop.fs.Path inputPath)

Methods inherited from class java.lang.Object

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

Field Detail

CONF_USER

public static final java.lang.String CONF_USER

A JobConf key which will specify the job's originating user

See Also:

Constant Field Values

CONF_LANGUAGE

public static final java.lang.String CONF_LANGUAGE

A JobConf key which will specify the language the job was written in.

See Also:

Constant Field Values

CONF_MAPPER

public static final java.lang.String CONF_MAPPER

See Also:

Constant Field Values

CONF_REDUCER

public static final java.lang.String CONF_REDUCER

See Also:

Constant Field Values

CONF_NUMERIC

public static final java.lang.String CONF_NUMERIC

See Also:

Constant Field Values

Constructor Detail

HadoopEngine

public HadoopEngine(org.apache.hadoop.conf.Configuration conf)
             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

submit

public void submit(JobRequest request,
                   long submissionID,
                   java.io.File mapperFile,
                   java.io.File reducerFile,
                   java.io.File packageDir,
                   org.apache.hadoop.fs.Path inputPath)
            throws ValidationException,
                   NotFoundException,
                   CompilationException,
                   InternalException

Specified by:

submit in interface JobEngine

Throws:

ValidationException

NotFoundException

CompilationException

InternalException

getInfo

public JobInfo getInfo(Submission submission,
                       org.apache.hadoop.mapred.RunningJob job,
                       org.apache.hadoop.mapred.JobConf conf)
                throws NotFoundException,
                       InternalException

Throws:

NotFoundException

InternalException

getStatus

public JobStatus getStatus(Submission submission)
                    throws NotFoundException,
                           InternalException

Specified by:

getStatus in interface JobEngine

Throws:

NotFoundException

InternalException

kill

public void kill(Submission submission)
          throws NotFoundException,
                 IllegalJobStateException,
                 InternalException

Specified by:

kill in interface JobEngine

Throws:

NotFoundException

IllegalJobStateException

InternalException