Class SourceSelection.ParallelGroupedCheckTask

java.lang.Object

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

org.eclipse.rdf4j.federated.optimizer.SourceSelection.ParallelSourceSelectionTask

org.eclipse.rdf4j.federated.optimizer.SourceSelection.ParallelGroupedCheckTask

All Implemented Interfaces:

ParallelTask<BindingSet>

Enclosing class:

SourceSelection

protected static class SourceSelection.ParallelGroupedCheckTask
extends SourceSelection.ParallelSourceSelectionTask

Author:

Andreas Schwarte

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<StatementPattern>	stmts

Fields inherited from class SourceSelection.ParallelSourceSelectionTask

control, endpoint, queryInfo

Fields inherited from class ParallelTaskBase

scheduledFuture

Constructor Summary

Constructors

Constructor	Description
ParallelGroupedCheckTask(Endpoint endpoint, List<StatementPattern> stmts, QueryInfo queryInfo, SourceSelection.SourceSelectionExecutorWithLatch control)

Method Summary

Modifier and Type	Method	Description
protected CloseableIteration<BindingSet>	performTaskInternal()

Methods inherited from class SourceSelection.ParallelSourceSelectionTask

cancel, getControl

Methods inherited from class ParallelTaskBase

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

stmts

protected final List<StatementPattern> stmts

Constructor Details

ParallelGroupedCheckTask

public ParallelGroupedCheckTask(Endpoint endpoint,
 List<StatementPattern> stmts,
 QueryInfo queryInfo,
 SourceSelection.SourceSelectionExecutorWithLatch control)

Method Details

performTaskInternal

protected CloseableIteration<BindingSet> performTaskInternal()
                                                      throws Exception

Specified by:

performTaskInternal in class ParallelTaskBase<BindingSet>

Throws:

Exception