Modifier and Type | Class and Description |
---|---|
class |
ParallelTaskBase<T> |
Modifier and Type | Method and Description |
---|---|
void |
Scheduler.schedule(ParallelTask<T> task)
Schedule the provided task.
|
void |
ControlledWorkerScheduler.schedule(ParallelTask<T> task)
Schedule the specified parallel task.
|
Modifier and Type | Method and Description |
---|---|
void |
ControlledWorkerScheduler.scheduleAll(List<ParallelTask<T>> tasks,
ParallelExecutor<T> control)
Schedule the given tasks and inform about finish using the same lock, i.e.
|
Modifier and Type | Class and Description |
---|---|
class |
ParallelBoundJoinTask
A task implementation representing a bound join, see
FederationEvalStrategy.evaluateBoundJoinStatementPattern(StatementTupleExpr, List) for further details on the
evaluation process. |
class |
ParallelCheckJoinTask
A task implementation representing a grouped bound check.
|
class |
ParallelJoinTask
A task implementation representing a join, i.e.
|
class |
ParallelLeftJoinTask
A task implementation representing a join, i.e.
|
class |
ParallelServiceJoinTask
A task implementation representing the evaluation of a SERVICE which is to be evaluated using block input.
|
Modifier and Type | Method and Description |
---|---|
ParallelTask<BindingSet> |
ControlledWorkerBoundJoin.TaskCreator.getTask(List<BindingSet> bindings) |
ParallelTask<BindingSet> |
ControlledWorkerBoundJoin.BoundJoinTaskCreator.getTask(List<BindingSet> bindings) |
ParallelTask<BindingSet> |
ControlledWorkerBoundJoin.CheckJoinTaskCreator.getTask(List<BindingSet> bindings) |
ParallelTask<BindingSet> |
ControlledWorkerBoundJoin.FedXServiceJoinTaskCreator.getTask(List<BindingSet> bindings) |
Modifier and Type | Class and Description |
---|---|
class |
ParallelGetStatementsTask
A task implementation to retrieve statements for a given
StatementPattern using the provided triple source. |
class |
ParallelPreparedAlgebraUnionTask
A task implementation representing a prepared union, i.e.
|
class |
ParallelPreparedUnionTask
A task implementation representing a prepared union, i.e.
|
class |
ParallelUnionOperatorTask
A task implementation representing a UNION operator expression to be evaluated.
|
class |
ParallelUnionTask
A task implementation representing a statement expression to be evaluated.
|
Modifier and Type | Field and Description |
---|---|
protected List<ParallelTask<T>> |
WorkerUnionBase.tasks |
Modifier and Type | Method and Description |
---|---|
void |
WorkerUnionBase.addTask(ParallelTask<T> task)
Add a generic parallel task.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
SourceSelection.ParallelCheckTask
Task for sending an ASK request to the endpoints (for source selection)
|
Modifier and Type | Field and Description |
---|---|
protected Set<ParallelTask<?>> |
QueryInfo.scheduledSubtasks |
Modifier and Type | Method and Description |
---|---|
void |
QueryInfo.registerScheduledTask(ParallelTask<?> task)
Register a new scheduled task for this query.
|
Copyright © 2015-2020 Eclipse Foundation. All Rights Reserved.