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

Class ParallelUnionTask

java.lang.Object

org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelTaskBase<BindingSet>

org.eclipse.rdf4j.federated.evaluation.union.ParallelUnionTask

All Implemented Interfaces:

ParallelTask<BindingSet>

public class ParallelUnionTask
extends ParallelTaskBase<BindingSet>

A task implementation representing a statement expression to be evaluated.

Author:

Andreas Schwarte

Field Summary

Fields

Modifier and Type	Field	Description
protected final BindingSet	bindings
protected final Endpoint	endpoint
protected final FilterValueExpr	filterExpr
protected final QueryInfo	queryInfo
protected final StatementPattern	stmt
protected final ParallelExecutor<BindingSet>	unionControl

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

scheduledFuture

Constructor Summary

Constructors

Constructor	Description
ParallelUnionTask(ParallelExecutor<BindingSet> unionControl, StatementPattern stmt, Endpoint endpoint, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)

Method Summary

Modifier and Type	Method	Description
ParallelExecutor<BindingSet>	getControl()	return the controlling instance, e.g.
protected CloseableIteration<BindingSet,QueryEvaluationException>	performTaskInternal()
String	toString()

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

cancel, close, performTask, setScheduledFuture

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

getQueryInfo

Field Details

endpoint

protected final Endpoint endpoint

stmt

protected final StatementPattern stmt

bindings

protected final BindingSet bindings

unionControl

protected final ParallelExecutor<BindingSet> unionControl

filterExpr

protected final FilterValueExpr filterExpr

queryInfo

protected final QueryInfo queryInfo

Constructor Details

ParallelUnionTask

public ParallelUnionTask(ParallelExecutor<BindingSet> unionControl,
 StatementPattern stmt,
 Endpoint endpoint,
 BindingSet bindings,
 FilterValueExpr filterExpr,
 QueryInfo queryInfo)

Method Details

performTaskInternal

protected CloseableIteration<BindingSet,QueryEvaluationException> performTaskInternal()
                                                                               throws Exception

Specified by:

performTaskInternal in class ParallelTaskBase<BindingSet>

Throws:

Exception

getControl

public ParallelExecutor<BindingSet> getControl()

Description copied from interface: ParallelTask

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

toString

public String toString()

Overrides:

toString in class ParallelTaskBase<BindingSet>