Class SourceSelection.ParallelCheckTask

java.lang.Object

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

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

org.eclipse.rdf4j.federated.optimizer.SourceSelection.ParallelCheckTask

All Implemented Interfaces:

ParallelTask<BindingSet>

Enclosing class:

SourceSelection

protected static class SourceSelection.ParallelCheckTask
extends SourceSelection.ParallelSourceSelectionTask

Task for sending an ASK request to the endpoints (for source selection)

Author:

Andreas Schwarte

Field Summary

Fields

Modifier and Type	Field	Description
protected final StatementPattern	stmt

Fields inherited from class SourceSelection.ParallelSourceSelectionTask

control, endpoint, queryInfo

Fields inherited from class ParallelTaskBase

scheduledFuture

Constructor Summary

Constructors

Constructor	Description
ParallelCheckTask(Endpoint endpoint, StatementPattern stmt, 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

stmt

protected final StatementPattern stmt

Constructor Details

ParallelCheckTask

public ParallelCheckTask(Endpoint endpoint,
 StatementPattern stmt,
 QueryInfo queryInfo,
 SourceSelection.SourceSelectionExecutorWithLatch control)

Method Details

performTaskInternal

protected CloseableIteration<BindingSet> performTaskInternal()
                                                      throws Exception

Specified by:

performTaskInternal in class ParallelTaskBase<BindingSet>

Throws:

Exception