com.bigdata.relation.rule.eval.pipeline

Class LocalJoinMasterTask

java.lang.Object

com.bigdata.relation.rule.eval.pipeline.JoinMasterTask

com.bigdata.relation.rule.eval.pipeline.LocalJoinMasterTask

All Implemented Interfaces:

IStepTask, IJoinMaster, Remote, Callable<RuleStats>

public class LocalJoinMasterTask
extends JoinMasterTask

Implementation for local join execution on a Journal.

Note: Just like a nested subquery join, when used for mutation this must read and write on the ITx.UNISOLATED indices and an UnisolatedReadWriteIndex will be used to serialize exclusive access to the unisolated index for writers while allowing readers concurrent access.

Version:

$Id: LocalJoinMasterTask.java 2625 2010-04-16 21:11:44Z mrpersonick $

Author:

Bryan Thompson

Field Summary

Fields inherited from class com.bigdata.relation.rule.eval.pipeline.JoinMasterTask

DEBUG, joinNexus, joinNexusFactory, joinStats, log, masterUUID, order, rule, ruleState, ruleStats, solutionBuffer, tailCount

Constructor Summary

Constructors

Constructor and Description
LocalJoinMasterTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer)

Method Summary

Methods

Modifier and Type	Method and Description
protected List<Future<Void>>	start() Applies an initial IBindingSet to the first join dimension.

Methods inherited from class com.bigdata.relation.rule.eval.pipeline.JoinMasterTask

awaitAll, call, combineJoinStats, getSolutionBuffer, getUUID, newBindingSetIterator, report

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalJoinMasterTask

public LocalJoinMasterTask(IRule rule,
                   IJoinNexus joinNexus,
                   IBuffer<ISolution[]> buffer)

Parameters:

rule -

joinNexus -

buffer -

Method Detail

start

protected List<Future<Void>> start()
                            throws Exception

Applies an initial IBindingSet to the first join dimension. Intermediate IBindingSets will propagate to each join dimension. The final IBindingSets will be generated by the last join dimension and written on the JoinMasterTask.getSolutionBuffer().

Returns:

The Future for the LocalJoinTask for each join dimension.

Throws:

Exception