org.galagosearch.tupleflow.execution
Class JobExecutor.JobExecutionStatus

java.lang.Object
  org.galagosearch.tupleflow.execution.JobExecutor.JobExecutionStatus

Enclosing class:

JobExecutor

public static class JobExecutor.JobExecutionStatus
extends java.lang.Object

Constructor Summary

JobExecutor.JobExecutionStatus(java.util.HashMap<java.lang.String,StageGroupDescription> stages, java.lang.String temporaryStorage, StageExecutor executor, java.lang.String masterURL)

Method Summary

long	getFreeMemory() Returns the total amount of free memory in this JVM.
long	getMaxMemory() Returns the maximum amount of memory that can be used by this Java virtual machine.
java.util.Map<java.lang.String,StageExecutionStatus>	getStageStatus()
java.util.Date	getStartDate() Returns the start date for this job.
boolean	isComplete()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobExecutor.JobExecutionStatus

public JobExecutor.JobExecutionStatus(java.util.HashMap<java.lang.String,StageGroupDescription> stages,
                                      java.lang.String temporaryStorage,
                                      StageExecutor executor,
                                      java.lang.String masterURL)

Method Detail

isComplete

public boolean isComplete()

getStageStatus

public java.util.Map<java.lang.String,StageExecutionStatus> getStageStatus()

getStartDate

public java.util.Date getStartDate()

Returns the start date for this job.

getFreeMemory

public long getFreeMemory()

Returns the total amount of free memory in this JVM.

getMaxMemory

public long getMaxMemory()

Returns the maximum amount of memory that can be used by this Java virtual machine.

run

public void run()
         throws java.lang.InterruptedException,
                java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException