Class ParallelTaskBase<T>
- java.lang.Object
-
- org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelTaskBase<T>
-
- All Implemented Interfaces:
ParallelTask<T>
- Direct Known Subclasses:
ParallelBoundJoinTask,ParallelCheckJoinTask,ParallelGetStatementsTask,ParallelJoinTask,ParallelLeftJoinTask,ParallelPreparedAlgebraUnionTask,ParallelPreparedUnionTask,ParallelServiceJoinTask,ParallelUnionOperatorTask,ParallelUnionTask,SourceSelection.ParallelCheckTask
public abstract class ParallelTaskBase<T> extends Object implements ParallelTask<T>
-
-
Field Summary
Fields Modifier and Type Field Description protected Future<?>scheduledFuture
-
Constructor Summary
Constructors Constructor Description ParallelTaskBase()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidcancel()Optional implementation to cancel this task on a best effort basisCloseableIteration<T,QueryEvaluationException>performTask()protected abstract CloseableIteration<T,QueryEvaluationException>performTaskInternal()voidsetScheduledFuture(Future<?> future)StringtoString()-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelTask
getControl, getQueryInfo
-
-
-
-
Field Detail
-
scheduledFuture
protected Future<?> scheduledFuture
-
-
Method Detail
-
cancel
public void cancel()
Description copied from interface:ParallelTaskOptional implementation to cancel this task on a best effort basis- Specified by:
cancelin interfaceParallelTask<T>
-
performTask
public CloseableIteration<T,QueryEvaluationException> performTask() throws Exception
- Specified by:
performTaskin interfaceParallelTask<T>- Throws:
Exception
-
performTaskInternal
protected abstract CloseableIteration<T,QueryEvaluationException> performTaskInternal() throws Exception
- Throws:
Exception
-
setScheduledFuture
public void setScheduledFuture(Future<?> future)
-
-