Uses of Interface
com.bigdata.relation.rule.eval.pipeline.IJoinMaster

Packages that use IJoinMaster

Package	Description
com.bigdata.relation.rule.eval.pipeline	This package implements a pipeline join.

Uses of IJoinMaster in com.bigdata.relation.rule.eval.pipeline

Classes in com.bigdata.relation.rule.eval.pipeline that implement IJoinMaster

Modifier and Type	Class and Description
class	DistributedJoinMasterTask Implementation for distributed join execution.
class	JoinMasterTask Master providing efficient distributed evaluation of IRules.
class	LocalJoinMasterTask Implementation for local join execution on a Journal.

Fields in com.bigdata.relation.rule.eval.pipeline declared as IJoinMaster

Modifier and Type	Field and Description
protected IJoinMaster	JoinTask.masterProxy A proxy for the remote JoinMasterTask.

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

Constructor and Description
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)
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.
JoinTaskFactoryTask(String scaleOutIndexName, IRule rule, IJoinNexusFactory joinNexusFactory, int[] order, int orderIndex, int partitionId, IJoinMaster masterProxy, UUID masterUUID, IAsynchronousIterator<IBindingSet[]> sourceItrProxy, IKeyOrder[] keyOrders, IVariable[][] requiredVars)
LocalJoinTask(IRule rule, IJoinNexus joinNexus, int[] order, int orderIndex, IJoinMaster masterProxy, UUID masterUUID, IAsynchronousIterator<IBindingSet[]> source, IBuffer<ISolution[]> solutionBuffer, IVariable[][] requiredVars)