edu.stolaf.cs.wmrserver.testjob
Class TestJobTask

java.lang.Object
  edu.stolaf.cs.wmrserver.testjob.TestJobTask

All Implemented Interfaces:

java.util.concurrent.Callable<TestJobResult>

public class TestJobTask
extends java.lang.Object
implements java.util.concurrent.Callable<TestJobResult>

Runs jobs as test jobs, capturing output from both the mapper and reducer executables. Since these jobs should only be run with small input, files are cut off after a certain number of bytes.

Field Summary

static long

EXECUTABLE_TIMEOUT

Constructor Summary

TestJobTask(org.apache.hadoop.conf.Configuration conf, long id, org.apache.hadoop.fs.Path inputPath, java.io.File mapperFile, java.io.File reducerFile, java.io.File packageDir, boolean numericSort)

Method Summary

TestJobResult	call()
protected TestJobResult.TransformResult	runTransform(long id, java.io.File executable, java.io.File workingDir, java.io.InputStream input)

Methods inherited from class java.lang.Object

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

Field Detail

EXECUTABLE_TIMEOUT

public static final long EXECUTABLE_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

TestJobTask

public TestJobTask(org.apache.hadoop.conf.Configuration conf,
                   long id,
                   org.apache.hadoop.fs.Path inputPath,
                   java.io.File mapperFile,
                   java.io.File reducerFile,
                   java.io.File packageDir,
                   boolean numericSort)

Method Detail

call

public TestJobResult call()
                   throws java.io.IOException

Specified by:

call in interface java.util.concurrent.Callable<TestJobResult>

Throws:

java.io.IOException

runTransform

protected TestJobResult.TransformResult runTransform(long id,
                                                     java.io.File executable,
                                                     java.io.File workingDir,
                                                     java.io.InputStream input)
                                              throws java.io.IOException

Throws:

java.io.IOException