Interface ParallelTask<T>
-
- All Known Implementing Classes:
ParallelBoundJoinTask
,ParallelCheckJoinTask
,ParallelGetStatementsTask
,ParallelJoinTask
,ParallelLeftJoinTask
,ParallelPreparedAlgebraUnionTask
,ParallelPreparedUnionTask
,ParallelServiceJoinTask
,ParallelTaskBase
,ParallelUnionOperatorTask
,ParallelUnionTask
,SourceSelection.ParallelCheckTask
public interface ParallelTask<T>
Interface for any parallel task that can be performed in Scheduler implementations.- Author:
- Andreas Schwarte
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
cancel()
Optional implementation to cancel this task on a best effort basisdefault void
close()
Optional implementation to close this task on a best effort basis.ParallelExecutor<T>
getControl()
return the controlling instance, e.g.default QueryInfo
getQueryInfo()
CloseableIteration<T,QueryEvaluationException>
performTask()
-
-
-
Method Detail
-
performTask
CloseableIteration<T,QueryEvaluationException> performTask() throws Exception
- Throws:
Exception
-
getControl
ParallelExecutor<T> getControl()
return the controlling instance, e.g. in most cases the instance of a thread. Shared variables are used to inform the thread about new events.- Returns:
- the control executor
-
cancel
void cancel()
Optional implementation to cancel this task on a best effort basis
-
close
default void close()
Optional implementation to close this task on a best effort basis.
-
-