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

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

Method Summary

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