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

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
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

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

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