com.bigdata.relation.rule.eval

Class AbstractJoinNexusFactory

java.lang.Object

com.bigdata.relation.rule.eval.AbstractJoinNexusFactory

All Implemented Interfaces:

IJoinNexusFactory, Serializable

Direct Known Subclasses:

MockJoinNexusFactory, RDFJoinNexusFactory

public abstract class AbstractJoinNexusFactory
extends Object
implements IJoinNexusFactory

Base implementation for IJoinNexusFactory.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractJoinNexusFactory(ActionEnum action, long writeTimestamp, long readTimestamp, Properties properties, int solutionFlags, IElementFilter<?> solutionFilter, IEvaluationPlanFactory evaluationPlanFactory, IRuleTaskFactory defaultRuleTaskFactory)

Method Summary

Methods

Modifier and Type	Method and Description
ActionEnum	getAction()
IRuleTaskFactory	getDefaultRuleTaskFactory()
IEvaluationPlanFactory	getEvaluationPlanFactory()
Properties	getProperties()
long	getReadTimestamp() The timestamp for the read view of the relation(s).
IElementFilter<?>	getSolutionFilter()
int	getSolutionFlags()
long	getWriteTimestamp() The timestamp for the write view of the relation(s).
IJoinNexus	newInstance(IIndexManager indexManager) Singleton factory for an IJoinNexus instance for the given indexManager.
protected abstract IJoinNexus	newJoinNexus(IIndexManager indexManager) Factory for IJoinNexus instances used by newInstance(IIndexManager) as past of its singleton pattern.
void	setReadTimestamp(long readTimestamp) Used by fix point closure operations to advance the read timestamp to the IIndexStore.getLastCommitTime() at the start of each round of closure.
String	toString()
protected void	toString(StringBuilder sb) Allows extension of toString() by derived classes.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJoinNexusFactory

protected AbstractJoinNexusFactory(ActionEnum action,
                        long writeTimestamp,
                        long readTimestamp,
                        Properties properties,
                        int solutionFlags,
                        IElementFilter<?> solutionFilter,
                        IEvaluationPlanFactory evaluationPlanFactory,
                        IRuleTaskFactory defaultRuleTaskFactory)

Parameters:

action - Indicates whether this is a Query, Insert, or Delete operation.

writeTimestamp - The timestamp of the relation view(s) using to write on the IMutableRelations (ignored if you are not execution mutation programs).

readTimestamp - The timestamp of the relation view(s) used to read from the access paths.

solutionFlags - Flags controlling the behavior of #newSolution(IRule, IBindingSet).

solutionFilter - An optional filter that will be applied to keep matching elements out of the IBuffer for Query or Mutation operations.

evaluationPlanFactory - The factory used to generate IEvaluationPlans for IRules.

defaultRuleTaskFactory - The factory that will be used to generate the IStepTask to execute an IRule unless the IRule explicitly specifies a factory object using IRule.getTaskFactory().

Method Detail

toString

public String toString()

Overrides:

toString in class Object

toString

protected void toString(StringBuilder sb)

Allows extension of toString() by derived classes.

Parameters:

sb -

newInstance

public IJoinNexus newInstance(IIndexManager indexManager)

Description copied from interface: IJoinNexusFactory

Singleton factory for an IJoinNexus instance for the given indexManager.

Note: The use of a singleton pattern helps to reduce the proliferation of distinct IJoinNexus instances for a given combination of IJoinNexusFactory and IIndexManager objects. A distinct IJoinNexus instance is of course generated when the IJoinNexusFactory is de-serialized, e.g., during RMI, and when a different IIndexManager is used.

Specified by:

newInstance in interface IJoinNexusFactory

Parameters:

indexManager - Used to locate relations and parallelize operations during rule execution.

newJoinNexus

protected abstract IJoinNexus newJoinNexus(IIndexManager indexManager)

Factory for IJoinNexus instances used by newInstance(IIndexManager) as past of its singleton pattern.

getAction

public final ActionEnum getAction()

Specified by:

getAction in interface IJoinNexusFactory

getProperties

public final Properties getProperties()

Specified by:

getProperties in interface IJoinNexusFactory

getReadTimestamp

public final long getReadTimestamp()

Description copied from interface: IJoinNexusFactory

The timestamp for the read view of the relation(s).

Specified by:

getReadTimestamp in interface IJoinNexusFactory

setReadTimestamp

public final void setReadTimestamp(long readTimestamp)

Description copied from interface: IJoinNexusFactory

Used by fix point closure operations to advance the read timestamp to the IIndexStore.getLastCommitTime() at the start of each round of closure.

Specified by:

setReadTimestamp in interface IJoinNexusFactory

getWriteTimestamp

public final long getWriteTimestamp()

Description copied from interface: IJoinNexusFactory

The timestamp for the write view of the relation(s).

Specified by:

getWriteTimestamp in interface IJoinNexusFactory

getSolutionFlags

public final int getSolutionFlags()

Specified by:

getSolutionFlags in interface IJoinNexusFactory

getSolutionFilter

public final IElementFilter<?> getSolutionFilter()

Specified by:

getSolutionFilter in interface IJoinNexusFactory

getEvaluationPlanFactory

public final IEvaluationPlanFactory getEvaluationPlanFactory()

Specified by:

getEvaluationPlanFactory in interface IJoinNexusFactory

getDefaultRuleTaskFactory

public final IRuleTaskFactory getDefaultRuleTaskFactory()

Specified by:

getDefaultRuleTaskFactory in interface IJoinNexusFactory