Package org.eclipse.rdf4j.federated.evaluation.union

Class WorkerUnionBase<T>

java.lang.Object

org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<T,QueryEvaluationException>

org.eclipse.rdf4j.common.iteration.LookAheadIteration<T,QueryEvaluationException>

org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase<T>

org.eclipse.rdf4j.federated.evaluation.union.UnionExecutorBase<T>

org.eclipse.rdf4j.federated.evaluation.union.WorkerUnionBase<T>

All Implemented Interfaces:

AutoCloseable, Runnable, CloseableIteration<T,QueryEvaluationException>, Iteration<T,QueryEvaluationException>, ParallelExecutor<T>

Direct Known Subclasses:

ControlledWorkerUnion, SynchronousWorkerUnion

public abstract class WorkerUnionBase<T>
extends UnionExecutorBase<T>

Base class for worker unions providing convenience functions to add tasks.

Author:

Andreas Schwarte

See Also:

• SynchronousWorkerUnion
• ControlledWorkerUnion

Field Summary

Fields

Modifier and Type	Field	Description
protected List<ParallelTask<T>>	tasks

Fields inherited from class org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase

evaluationThread, executorId, finished, log, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy

Constructor Summary

Constructors

Constructor	Description
WorkerUnionBase(QueryInfo queryInfo)

Method Summary

Modifier and Type	Method	Description
void	addTask(ParallelTask<T> task)	Add a generic parallel task.
void	handleClose()	Called by AbstractCloseableIteration.close() when it is called for the first time.

Methods inherited from class org.eclipse.rdf4j.federated.evaluation.union.UnionExecutorBase

getExecutorType, performExecution, union

Methods inherited from class org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase

addResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, isFinished, run, toss, toString

Methods inherited from class org.eclipse.rdf4j.common.iteration.LookAheadIteration

hasNext, next, remove

Methods inherited from class org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration

close, isClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.rdf4j.common.iteration.CloseableIteration

stream

Field Details

tasks

protected List<ParallelTask<T>> tasks

Constructor Details

WorkerUnionBase

public WorkerUnionBase(QueryInfo queryInfo)

Method Details

addTask

public void addTask(ParallelTask<T> task)

Add a generic parallel task. Note that it is required that the task has this instance as its control.

Parameters:

task -

handleClose

public void handleClose()
                 throws QueryEvaluationException

Description copied from class: AbstractCloseableIteration

Called by AbstractCloseableIteration.close() when it is called for the first time. This method is only called once on each iteration. By default, this method does nothing.

Overrides:

handleClose in class ParallelExecutorBase<T>

Throws:

QueryEvaluationException