|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use IJoinNexus | |
|---|---|
| com.bigdata.bop.joinGraph | This package provides support for join graphs, query optimization, and generating full query plans from a join graph and the evaluation order identified by a query optimizer. |
| com.bigdata.bop.joinGraph.fast | |
| com.bigdata.rdf.rules | |
| com.bigdata.relation.rule.eval | This package supports rule evaluation. |
| com.bigdata.relation.rule.eval.pipeline | This package implements a pipeline join. |
| Uses of IJoinNexus in com.bigdata.bop.joinGraph |
|---|
| Fields in com.bigdata.bop.joinGraph declared as IJoinNexus | |
|---|---|
protected IJoinNexus |
NoReorderEvaluationPlan.joinNexus
|
| Methods in com.bigdata.bop.joinGraph with parameters of type IJoinNexus | |
|---|---|
IEvaluationPlan |
NOPEvaluationPlanFactory.newPlan(IJoinNexus joinNexus,
IRule rule)
|
IEvaluationPlan |
FixedEvaluationPlanFactory.newPlan(IJoinNexus joinNexus,
IRule rule)
|
IEvaluationPlan |
IEvaluationPlanFactory.newPlan(IJoinNexus joinNexus,
IRule rule)
Return a plan for the rule. |
| Constructors in com.bigdata.bop.joinGraph with parameters of type IJoinNexus | |
|---|---|
DefaultRangeCountFactory(IJoinNexus joinNexus)
|
|
NoReorderEvaluationPlan(IJoinNexus joinNexus,
IRule rule)
|
|
| Uses of IJoinNexus in com.bigdata.bop.joinGraph.fast |
|---|
| Methods in com.bigdata.bop.joinGraph.fast with parameters of type IJoinNexus | |
|---|---|
IEvaluationPlan |
DefaultEvaluationPlanFactory2.newPlan(IJoinNexus joinNexus,
IRule rule)
|
| Constructors in com.bigdata.bop.joinGraph.fast with parameters of type IJoinNexus | |
|---|---|
DefaultEvaluationPlan2(IJoinNexus joinNexus,
IRule rule)
Computes an evaluation plan for the rule. |
|
| Uses of IJoinNexus in com.bigdata.rdf.rules |
|---|
| Classes in com.bigdata.rdf.rules that implement IJoinNexus | |
|---|---|
class |
RDFJoinNexus
IProgram execution support for the RDF DB. |
| Methods in com.bigdata.rdf.rules that return IJoinNexus | |
|---|---|
protected IJoinNexus |
RDFJoinNexusFactory.newJoinNexus(IIndexManager indexManager)
|
| Constructors in com.bigdata.rdf.rules with parameters of type IJoinNexus | |
|---|---|
AbstractRuleDistinctTermScan.DistinctTermScan(IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> buffer,
IVariable<IV> h,
SPOKeyOrder keyOrder)
|
|
AbstractRuleFastClosure_3_5_6_7_9.FastClosureRuleTask(String database,
String focusStore,
IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> buffer,
IConstant<IV> rdfsSubPropertyOf,
IConstant<IV> propertyId)
(?x, {P}, ?y) -> (?x, propertyId, ?y)
Note: Both the database and the (optional) focusStore relation names
MUST be declared for these rules. |
|
| Uses of IJoinNexus in com.bigdata.relation.rule.eval |
|---|
| Classes in com.bigdata.relation.rule.eval that implement IJoinNexus | |
|---|---|
class |
AbstractJoinNexus
Base implementation for IJoinNexus |
| Methods in com.bigdata.relation.rule.eval that return IJoinNexus | |
|---|---|
IJoinNexus |
IJoinNexusFactory.newInstance(IIndexManager indexManager)
Singleton factory for an IJoinNexus instance for the given
indexManager. |
IJoinNexus |
AbstractJoinNexusFactory.newInstance(IIndexManager indexManager)
|
protected abstract IJoinNexus |
AbstractJoinNexusFactory.newJoinNexus(IIndexManager indexManager)
Factory for IJoinNexus instances used by
AbstractJoinNexusFactory.newInstance(IIndexManager) as past of its singleton pattern. |
| Methods in com.bigdata.relation.rule.eval with parameters of type IJoinNexus | |
|---|---|
protected IKeyOrder[] |
RuleState.computeKeyOrderForEachTail(IRule rule,
IJoinNexus joinNexus,
int[] order,
int[] nvars)
Return an array indicating the IKeyOrder that will be used when
reading on each of the tail predicates. |
protected void |
MutationTask.flushBuffers(IJoinNexus joinNexus,
Map<String,IBuffer<ISolution[]>> buffers)
Flush the buffer(s) and aggregate the mutation count from each buffer. |
protected Map<String,IBuffer<ISolution[]>> |
AbstractStepTask.getMutationBuffers(IJoinNexus joinNexus,
Map<String,IRelation> relations)
Create the appropriate buffers to absorb writes by the rules in the program that target an IMutableRelation. |
protected List<Callable<RuleStats>> |
MutationTask.newMutationTasks(IStep step,
IJoinNexus joinNexus,
Map<String,IBuffer<ISolution[]>> buffers)
Builds a set of tasks for the program. |
protected List<Callable<RuleStats>> |
QueryTask.newQueryTasks(IStep step,
IJoinNexus joinNexus,
IBlockingBuffer<ISolution[]> buffer)
Builds a set of tasks for the program. |
IStepTask |
RunRuleAndFlushBufferTaskFactory.newTask(IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> buffer)
Deprecated. |
IStepTask |
IRuleTaskFactory.newTask(IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> buffer)
The object will be used to evaluate the rule for the IRule. |
IStepTask |
DefaultRuleTaskFactory.newTask(IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> buffer)
|
protected RuleStats |
AbstractStepTask.runOne(IJoinNexus joinNexus,
IStep program,
Callable<RuleStats> task)
Run a single step (sequence of one). |
protected RuleStats |
AbstractStepTask.runParallel(IJoinNexus joinNexus,
IStep program,
List<Callable<RuleStats>> tasks)
Run program steps in parallel. |
protected RuleStats |
AbstractStepTask.runSequential(IJoinNexus joinNexus,
IStep program,
List<Callable<RuleStats>> tasks)
Run program steps in sequence. |
protected RuleStats |
QueryTask.runTasks(IJoinNexus joinNexus,
List<Callable<RuleStats>> tasks)
Run the task(s) and wait for them to complete. |
| Constructors in com.bigdata.relation.rule.eval with parameters of type IJoinNexus | |
|---|---|
RuleState(IRule rule,
IJoinNexus joinNexus)
|
|
Solution(IJoinNexus joinNexus,
IRule<E> rule,
IBindingSet bindingSet)
Constructs the element iff requested, saves the rule reference iff requested, and clones and saves the bindingSet iff requested. |
|
| Uses of IJoinNexus in com.bigdata.relation.rule.eval.pipeline |
|---|
| Fields in com.bigdata.relation.rule.eval.pipeline declared as IJoinNexus | |
|---|---|
protected IJoinNexus |
DistributedJoinTask.fedJoinNexus
The IJoinNexus for the IBigdataFederation. |
protected IJoinNexus |
JoinMasterTask.joinNexus
|
protected IJoinNexus |
JoinTask.joinNexus
The IJoinNexus for the local IIndexManager, which
will be the live IJournal. |
| Constructors in com.bigdata.relation.rule.eval.pipeline with parameters of type IJoinNexus | |
|---|---|
DistributedJoinMasterTask(IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> buffer)
|
|
DistributedJoinTask(IRule rule,
IJoinNexus joinNexus,
int[] order,
int orderIndex,
int partitionId,
AbstractScaleOutFederation<?> fed,
IJoinMaster master,
UUID masterUUID,
IAsynchronousIterator<IBindingSet[]> src,
IKeyOrder[] keyOrders,
DataService dataService,
IVariable[][] requiredVars)
|
|
JoinMasterTask(IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> solutionBuffer)
|
|
JoinTask(IRule rule,
IJoinNexus joinNexus,
int[] order,
int orderIndex,
int partitionId,
IJoinMaster masterProxy,
UUID masterUUID,
IVariable[][] requiredVars)
Instances of this class MUST be created in the appropriate execution context of the target DataService so that the federation and
the joinNexus references are both correct and so that it has access
to the local index object for the specified index partition. |
|
LocalJoinMasterTask(IRule rule,
IJoinNexus joinNexus,
IBuffer<ISolution[]> buffer)
|
|
LocalJoinTask(IRule rule,
IJoinNexus joinNexus,
int[] order,
int orderIndex,
IJoinMaster masterProxy,
UUID masterUUID,
IAsynchronousIterator<IBindingSet[]> source,
IBuffer<ISolution[]> solutionBuffer,
IVariable[][] requiredVars)
|
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||