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 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. in most cases the instance of a thread.
protected CloseableIteration<BindingSet>	performTaskInternal()	Deprecated, for removal: This API element is subject to removal in a future version.

Methods inherited from class ParallelTaskBase

cancel, close, performTask, setScheduledFuture, toString

Methods inherited from class Object

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

Methods inherited from interface 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