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

Modifier and Type	Field	Description
protected final SourceSelection.SourceSelectionExecutorWithLatch	control
protected final Endpoint	endpoint
protected final QueryInfo	queryInfo

Fields inherited from class ParallelTaskBase

scheduledFuture

Modifier and Type	Field	Description
protected Future<?>	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

Modifier and Type	Method	Description
void	cancel()	Optional implementation to cancel this task on a best effort basis
ParallelExecutor<BindingSet>	getControl()	return the controlling instance, e.g. in most cases the instance of a thread.

Methods inherited from class ParallelTaskBase

close, performTask, setScheduledFuture, toString

Modifier and Type	Method	Description
void	close()	Optional implementation to close this task on a best effort basis.
CloseableIteration<BindingSet>	performTask()
void	setScheduledFuture(Future<?> future)
String	toString()

Methods inherited from class Object

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

Methods inherited from interface ParallelTask

getQueryInfo

Modifier and Type	Method	Description
default QueryInfo	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