com.bigdata.relation.rule.eval.pipeline

Class JoinTaskFactoryTask

java.lang.Object

com.bigdata.service.FederationCallable<T>

com.bigdata.service.DataServiceCallable<Future>

com.bigdata.relation.rule.eval.pipeline.JoinTaskFactoryTask

All Implemented Interfaces:

IDataServiceCallable, IFederationCallable, Serializable, Callable<Future>

public class JoinTaskFactoryTask
extends DataServiceCallable<Future>

A factory for DistributedJoinTasks. The factory either creates a new DistributedJoinTask or returns the pre-existing DistributedJoinTask for the given JoinMasterTask instance (as identified by its UUID), orderIndex, and partitionId. When the desired join task pre-exists, factory will invoke DistributedJoinTask.addSource(IAsynchronousIterator) and specify the sourceItrProxy as another source for that join task.

The use of a factory pattern allows us to concentrate all DistributedJoinTasks which target the same tail predicate and index partition for the same rule execution instance onto the same DistributedJoinTask. The concentrator effect achieved by the factory only matters when the fan-out is GT ONE (1).

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
JoinTaskFactoryTask(String scaleOutIndexName, IRule rule, IJoinNexusFactory joinNexusFactory, int[] order, int orderIndex, int partitionId, IJoinMaster masterProxy, UUID masterUUID, IAsynchronousIterator<IBindingSet[]> sourceItrProxy, IKeyOrder[] keyOrders, IVariable[][] requiredVars)

Method Summary

Methods

Modifier and Type	Method and Description
Future	call() Either starts a new DistributedJoinTask and returns its Future or returns the Future of an existing DistributedJoinTask for the same DistributedJoinMasterTask instance, orderIndex, and partitionId.
static String	getJoinTaskNamespace(UUID masterUUID, int orderIndex, int partitionId)
protected DistributedJoinTask	newJoinTask()
protected Future<Void>	submit(DistributedJoinTask task)
String	toString()

Methods inherited from class com.bigdata.service.DataServiceCallable

getDataService, isDataService, setDataService

Methods inherited from class com.bigdata.service.FederationCallable

getFederation, setFederation

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.service.IFederationCallable

getFederation, setFederation

Field Detail

log

protected static final transient org.apache.log4j.Logger log

Constructor Detail

JoinTaskFactoryTask

public JoinTaskFactoryTask(String scaleOutIndexName,
                   IRule rule,
                   IJoinNexusFactory joinNexusFactory,
                   int[] order,
                   int orderIndex,
                   int partitionId,
                   IJoinMaster masterProxy,
                   UUID masterUUID,
                   IAsynchronousIterator<IBindingSet[]> sourceItrProxy,
                   IKeyOrder[] keyOrders,
                   IVariable[][] requiredVars)

Parameters:

scaleOutIndexName -

rule -

joinNexusFactory -

order -

orderIndex -

partitionId -

masterProxy -

masterUUID - (Avoids RMI to obtain this later).

sourceItrProxy -

nextScaleOutIndexName -

Method Detail

toString

public String toString()

Overrides:

toString in class Object

call

public Future call()
            throws Exception

Either starts a new DistributedJoinTask and returns its Future or returns the Future of an existing DistributedJoinTask for the same DistributedJoinMasterTask instance, orderIndex, and partitionId.

Returns:

(A proxy for) the Future of the DistributedJoinTask.

Throws:

Exception

newJoinTask

protected DistributedJoinTask newJoinTask()

submit

protected Future<Void> submit(DistributedJoinTask task)

getJoinTaskNamespace

public static String getJoinTaskNamespace(UUID masterUUID,
                          int orderIndex,
                          int partitionId)

Parameters:

masterUUID - The master UUID should be cached locally by the JoinTask so that invoking this method does not require RMI.

orderIndex -

partitionId -

Returns: