edu.stolaf.cs.wmrserver
Class TestJobEngine

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

All Implemented Interfaces:

JobEngine

public class TestJobEngine
extends java.lang.Object
implements JobEngine

Method Summary

JobInfo	getInfo(Submission submission)
java.lang.String	getOutput(Submission submission, int page)
protected TestJobResult	getResult(long submissionID)
JobStatus	getStatus(Submission submission)
protected boolean	isComplete(long submissionID)
protected boolean	isKilled(long submissionID)
protected boolean	kill(long submissionID)
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)
protected void	submit(long submissionID, TestJobTask job)

Methods inherited from class java.lang.Object

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

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,
                   ForbiddenTestJobException

Specified by:

submit in interface JobEngine

Throws:

ValidationException

NotFoundException

CompilationException

InternalException

ForbiddenTestJobException

getInfo

public JobInfo getInfo(Submission submission)
                throws NotFoundException,
                       InternalException

Throws:

NotFoundException

InternalException

getStatus

public JobStatus getStatus(Submission submission)
                    throws NotFoundException,
                           InternalException

Specified by:

getStatus in interface JobEngine

Throws:

NotFoundException

InternalException

getOutput

public java.lang.String getOutput(Submission submission,
                                  int page)
                           throws IllegalJobStateException

Throws:

IllegalJobStateException

kill

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

Specified by:

kill in interface JobEngine

Throws:

NotFoundException

IllegalJobStateException

InternalException

submit

protected void submit(long submissionID,
                      TestJobTask job)

kill

protected boolean kill(long submissionID)
                throws NotFoundException

Throws:

NotFoundException

isComplete

protected boolean isComplete(long submissionID)
                      throws NotFoundException

Throws:

NotFoundException

isKilled

protected boolean isKilled(long submissionID)
                    throws NotFoundException

Throws:

NotFoundException

getResult

protected TestJobResult getResult(long submissionID)
                           throws NotFoundException,
                                  java.util.concurrent.ExecutionException,
                                  java.util.concurrent.CancellationException

Throws:

NotFoundException

java.util.concurrent.ExecutionException

java.util.concurrent.CancellationException