Uses of Interface
com.bigdata.relation.rule.eval.IJoinNexus

Packages that use IJoinNexus

Package	Description
com.bigdata.bop.ap
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.ap

Methods in com.bigdata.bop.ap that return IJoinNexus

Modifier and Type	Method and Description
protected IJoinNexus	MockJoinNexusFactory.newJoinNexus(IIndexManager indexManager)

Uses of IJoinNexus in com.bigdata.bop.joinGraph

Fields in com.bigdata.bop.joinGraph declared as IJoinNexus

Modifier and Type	Field and Description
protected IJoinNexus	NoReorderEvaluationPlan.joinNexus

Methods in com.bigdata.bop.joinGraph with parameters of type IJoinNexus

Modifier and Type	Method and Description
IEvaluationPlan	FixedEvaluationPlanFactory.newPlan(IJoinNexus joinNexus, IRule rule)
IEvaluationPlan	IEvaluationPlanFactory.newPlan(IJoinNexus joinNexus, IRule rule) Return a plan for the rule.
IEvaluationPlan	NOPEvaluationPlanFactory.newPlan(IJoinNexus joinNexus, IRule rule)

Constructors in com.bigdata.bop.joinGraph with parameters of type IJoinNexus

Constructor and Description
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

Modifier and Type	Method and Description
IEvaluationPlan	DefaultEvaluationPlanFactory2.newPlan(IJoinNexus joinNexus, IRule rule)

Constructors in com.bigdata.bop.joinGraph.fast with parameters of type IJoinNexus

Constructor and Description
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

Modifier and Type	Class and Description
class	RDFJoinNexus IProgram execution support for the RDF DB.

Methods in com.bigdata.rdf.rules that return IJoinNexus

Modifier and Type	Method and Description
protected IJoinNexus	RDFJoinNexusFactory.newJoinNexus(IIndexManager indexManager)

Constructors in com.bigdata.rdf.rules with parameters of type IJoinNexus

Constructor and Description
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

Modifier and Type	Class and Description
class	AbstractJoinNexus Base implementation for IJoinNexus

Methods in com.bigdata.relation.rule.eval that return IJoinNexus

Modifier and Type	Method and Description
IJoinNexus	AbstractJoinNexusFactory.newInstance(IIndexManager indexManager)
IJoinNexus	IJoinNexusFactory.newInstance(IIndexManager indexManager) Singleton factory for an IJoinNexus instance for the given 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

Modifier and Type	Method and Description
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	DefaultRuleTaskFactory.newTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer)
IStepTask	IRuleTaskFactory.newTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer) The object will be used to evaluate the rule for the IRule.
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

Constructor and Description
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

Modifier and Type	Field and Description
protected IJoinNexus	DistributedJoinTask.fedJoinNexus The IJoinNexus for the IBigdataFederation.
protected IJoinNexus	JoinTask.joinNexus The IJoinNexus for the local IIndexManager, which will be the live IJournal.
protected IJoinNexus	JoinMasterTask.joinNexus

Constructors in com.bigdata.relation.rule.eval.pipeline with parameters of type IJoinNexus

Constructor and Description
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)