org.galagosearch.tupleflow.execution
Class LocalStageExecutor.SequentialExecutionContext

java.lang.Object
  org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext

All Implemented Interfaces:

java.lang.Runnable, StageExecutionStatus

Enclosing class:

LocalStageExecutor

public static class LocalStageExecutor.SequentialExecutionContext
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	markDone()
void	run()

Methods inherited from class java.lang.Object

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

Method Detail

markDone

public void markDone()

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

isDone

public boolean isDone()

Specified by:

isDone in interface StageExecutionStatus

getExceptions

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

Specified by:

getExceptions in interface StageExecutionStatus