Package se.liu.ida.hefquin.engine.queryplan.executable.impl

Class TaskBasedExecutablePlanImpl

java.lang.Object

se.liu.ida.hefquin.engine.queryplan.executable.impl.TaskBasedExecutablePlanImpl

All Implemented Interfaces:

StatsProvider, ExecutablePlan

public class TaskBasedExecutablePlanImpl
extends Object
implements ExecutablePlan

Field Summary

Fields

Modifier and Type	Field	Description
protected final LinkedList<ExecPlanTask>	tasks
protected ExecutorService	threadPool

Constructor Summary

Constructors

Constructor	Description
TaskBasedExecutablePlanImpl(LinkedList<ExecPlanTask> tasks, ExecutionContext ctx)

Method Summary

Modifier and Type	Method	Description
List<Exception>	getExceptionsCaughtDuringExecution()	Returns exceptions that were caught and collected during the execution of this plan (if any).
ExecutablePlanStats	getStats()
void	print(PrintStream str)
void	resetStats()
void	run(QueryResultSink resultSink)

Methods inherited from class java.lang.Object

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

Field Details

tasks

protected final LinkedList<ExecPlanTask> tasks

threadPool

protected ExecutorService threadPool

Constructor Details

TaskBasedExecutablePlanImpl

public TaskBasedExecutablePlanImpl(LinkedList<ExecPlanTask> tasks,
 ExecutionContext ctx)

Method Details

run

public void run(QueryResultSink resultSink)
         throws ExecutionException

Specified by:

run in interface ExecutablePlan

Throws:

ExecutionException

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

getStats

public ExecutablePlanStats getStats()

Specified by:

getStats in interface ExecutablePlan

Specified by:

getStats in interface StatsProvider

getExceptionsCaughtDuringExecution

public List<Exception> getExceptionsCaughtDuringExecution()

Description copied from interface: ExecutablePlan

Returns exceptions that were caught and collected during the execution of this plan (if any). If no exceptions were caught (which should be the normal case), then this function returns an empty list.

Specified by:

getExceptionsCaughtDuringExecution in interface ExecutablePlan

print

public void print(PrintStream str)