Class WorkerUnionBase<T>

java.lang.Object

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

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

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, Iterator<T>, CloseableIteration<T>, 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 ParallelExecutorBase

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

Fields inherited from interface CloseableIteration

EMPTY_STATEMENT_ITERATION

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 UnionExecutorBase

getExecutorType, performExecution, union

Methods inherited from class ParallelExecutorBase

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

Methods inherited from class LookAheadIteration

hasNext, next, remove

Methods inherited from class AbstractCloseableIteration

close, isClosed

Methods inherited from class Object

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

Methods inherited from interface CloseableIteration

stream

Methods inherited from interface Iterator

forEachRemaining

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