Class ParallelCheckJoinTask

java.lang.Object

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

org.eclipse.rdf4j.federated.evaluation.join.ParallelCheckJoinTask

All Implemented Interfaces:

ParallelTask<BindingSet>

@Deprecated(forRemoval=true)
public class ParallelCheckJoinTask
extends ParallelTaskBase<BindingSet>

Deprecated, for removal: This API element is subject to removal in a future version.

now integrated in ParallelBoundJoinTask (with VALUES clause)

A task implementation representing a grouped bound check. See FederationEvalStrategy.evaluateGroupedCheck(CheckStatementPattern, List) for further details.

Author:

Andreas Schwarte

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<BindingSet>	bindings	Deprecated, for removal: This API element is subject to removal in a future version.
protected final CheckStatementPattern	expr	Deprecated, for removal: This API element is subject to removal in a future version.
protected final ParallelExecutor<BindingSet>	joinControl	Deprecated, for removal: This API element is subject to removal in a future version.
protected final FederationEvalStrategy	strategy	Deprecated, for removal: This API element is subject to removal in a future version.

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

scheduledFuture

Constructor Summary

Constructors

Constructor	Description
ParallelCheckJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, CheckStatementPattern expr, List<BindingSet> bindings)	Deprecated, for removal: This API element is subject to removal in a future version.

Method Summary

Modifier and Type	Method	Description
ParallelExecutor<BindingSet>	getControl()	Deprecated, for removal: This API element is subject to removal in a future version. return the controlling instance, e.g.
protected CloseableIteration<BindingSet>	performTaskInternal()	Deprecated, for removal: This API element is subject to removal in a future version.

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

cancel, close, performTask, setScheduledFuture, toString

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

strategy

protected final FederationEvalStrategy strategy

Deprecated, for removal: This API element is subject to removal in a future version.

expr

protected final CheckStatementPattern expr

Deprecated, for removal: This API element is subject to removal in a future version.

bindings

protected final List<BindingSet> bindings

Deprecated, for removal: This API element is subject to removal in a future version.

joinControl

protected final ParallelExecutor<BindingSet> joinControl

Deprecated, for removal: This API element is subject to removal in a future version.

Constructor Details

ParallelCheckJoinTask

public ParallelCheckJoinTask(ParallelExecutor<BindingSet> joinControl,
 FederationEvalStrategy strategy,
 CheckStatementPattern expr,
 List<BindingSet> bindings)

Deprecated, for removal: This API element is subject to removal in a future version.

Method Details

performTaskInternal

protected CloseableIteration<BindingSet> performTaskInternal()
                                                      throws Exception

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

performTaskInternal in class ParallelTaskBase<BindingSet>

Throws:

Exception

getControl

public ParallelExecutor<BindingSet> getControl()

Deprecated, for removal: This API element is subject to removal in a future version.

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