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

Class ParallelPreparedAlgebraUnionTask

java.lang.Object

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

org.eclipse.rdf4j.federated.evaluation.union.ParallelPreparedAlgebraUnionTask

All Implemented Interfaces:

ParallelTask<BindingSet>

public class ParallelPreparedAlgebraUnionTask
extends ParallelTaskBase<BindingSet>

A task implementation representing a prepared union, i.e. the prepared query is executed on the provided triple source.

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 TupleExpr	preparedQuery
protected final QueryInfo	queryInfo
protected final ParallelExecutor<BindingSet>	unionControl

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

scheduledFuture

Constructor Summary

Constructors

Constructor	Description
ParallelPreparedAlgebraUnionTask(ParallelExecutor<BindingSet> unionControl, TupleExpr preparedQuery, 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, 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

preparedQuery

protected final TupleExpr preparedQuery

bindings

protected final BindingSet bindings

unionControl

protected final ParallelExecutor<BindingSet> unionControl

filterExpr

protected final FilterValueExpr filterExpr

queryInfo

protected final QueryInfo queryInfo

Constructor Details

ParallelPreparedAlgebraUnionTask

public ParallelPreparedAlgebraUnionTask(ParallelExecutor<BindingSet> unionControl,
 TupleExpr preparedQuery,
 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>