org.galagosearch.tupleflow.execution
Class ThreadedStageExecutor.ThreadedStageContext

java.lang.Object
  org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext

All Implemented Interfaces:

java.lang.Runnable, StageExecutionStatus

Enclosing class:

ThreadedStageExecutor

public class ThreadedStageExecutor.ThreadedStageContext
extends java.lang.Object
implements StageExecutionStatus, java.lang.Runnable

Method Summary

int	getBlockedInstances()
int	getCompletedInstances()
java.util.List<java.lang.Exception>	getExceptions()
java.lang.String	getName()
int	getQueuedInstances()
int	getRunningInstances()
boolean	isDone()
void	run()

Methods inherited from class java.lang.Object

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

Method Detail

isDone

public boolean isDone()

Specified by:

isDone in interface StageExecutionStatus

run

public void run()

Specified by:

run in interface java.lang.Runnable

getName

public java.lang.String getName()

Specified by:

getName in interface StageExecutionStatus

getBlockedInstances

public int getBlockedInstances()

Specified by:

getBlockedInstances in interface StageExecutionStatus

getQueuedInstances

public int getQueuedInstances()

Specified by:

getQueuedInstances in interface StageExecutionStatus

getRunningInstances

public int getRunningInstances()

Specified by:

getRunningInstances in interface StageExecutionStatus

getCompletedInstances

public int getCompletedInstances()

Specified by:

getCompletedInstances in interface StageExecutionStatus

getExceptions

public java.util.List<java.lang.Exception> getExceptions()

Specified by:

getExceptions in interface StageExecutionStatus