Class SourceSelection.ParallelSourceSelectionTask

java.lang.Object

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

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

All Implemented Interfaces:

ParallelTask<BindingSet>

Direct Known Subclasses:

SourceSelection.ParallelCheckTask, SourceSelection.ParallelGroupedCheckTask

Enclosing class:

SourceSelection

protected abstract static class SourceSelection.ParallelSourceSelectionTask
extends ParallelTaskBase<BindingSet>

Author:

Andreas Schwarte

Field Summary

Fields

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
ParallelSourceSelectionTask(Endpoint endpoint, QueryInfo queryInfo, SourceSelection.SourceSelectionExecutorWithLatch control)

Method Summary

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, performTaskInternal, setScheduledFuture, toString

Modifier and Type	Method	Description
void	close()	Optional implementation to close this task on a best effort basis.
CloseableIteration<BindingSet>	performTask()
protected abstract CloseableIteration<BindingSet>	performTaskInternal()
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

endpoint

protected final Endpoint endpoint

control

protected final SourceSelection.SourceSelectionExecutorWithLatch control

queryInfo

protected final QueryInfo queryInfo

Constructor Details

ParallelSourceSelectionTask

public ParallelSourceSelectionTask(Endpoint endpoint,
 QueryInfo queryInfo,
 SourceSelection.SourceSelectionExecutorWithLatch control)

Method Details

getControl

public ParallelExecutor<BindingSet> getControl()

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

cancel

public void cancel()

Description copied from interface: ParallelTask

Optional implementation to cancel this task on a best effort basis

Specified by:

cancel in interface ParallelTask<BindingSet>

Overrides:

cancel in class ParallelTaskBase<BindingSet>