Package | Description |
---|---|
com.bigdata.relation.rule.eval.pipeline |
This package implements a pipeline join.
|
Modifier and Type | Method and Description |
---|---|
protected JoinTask.AccessPathTask[] |
JoinTask.BindingSetConsumerTask.getAccessPathTasks(Map<IPredicate<?>,Collection<IBindingSet>> map)
Creates an
JoinTask.AccessPathTask for each IBindingSet in
the given chunk. |
Modifier and Type | Method and Description |
---|---|
int |
JoinTask.AccessPathTask.compareTo(JoinTask.AccessPathTask o)
Imposes an order based on the fromKey for the
IAccessPath associated with the task. |
boolean |
JoinTask.AccessPathTask.equals(JoinTask.AccessPathTask o)
Return
true iff the tasks are equivalent (same as
bound predicate). |
protected void |
JoinTask.BindingSetConsumerTask.executeTasks(JoinTask.AccessPathTask[] tasks)
Either execute the tasks in the caller's thread or schedule them
for execution on the supplied service.
|
protected void |
JoinTask.BindingSetConsumerTask.reorderTasks(JoinTask.AccessPathTask[] tasks)
The tasks are ordered based on the fromKey for the
associated
IAccessPath as licensed by each
IBindingSet . |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.