org.eclipse.viatra.query.runtime.rete.network

Class StandardNode

java.lang.Object

org.eclipse.viatra.query.runtime.rete.network.BaseNode

org.eclipse.viatra.query.runtime.rete.network.StandardNode

All Implemented Interfaces:

Node, Supplier

Direct Known Subclasses:

ConstantNode, DualInputNode, ExternalInputEnumeratorNode, IndexerBasedAggregatorNode, SingleInputNode, UniquenessEnforcerNode

public abstract class StandardNode
extends BaseNode
implements Supplier

Base implementation for a supplier node.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<Receiver>	children

Fields inherited from class org.eclipse.viatra.query.runtime.rete.network.BaseNode

nodeId, reteContainer, tag, traceInfos

Constructor Summary

Constructors

Constructor and Description
StandardNode(ReteContainer reteContainer)

Method Summary

Modifier and Type	Method and Description
void	appendChild(Receiver receiver) appends a receiver that will continously receive insert and revoke updates from this supplier
ProjectionIndexer	constructIndex(TupleMask mask, TraceInfo... traces) Instantiates (or reuses, depending on implementation) an index according to the given mask.
java.util.Set<Tuple>	getPulledContents() Returns the contents of this object in this particular moment.
java.util.Collection<Receiver>	getReceivers() lists receivers
protected void	issueError(java.lang.String message, java.lang.Exception ex)
protected void	propagateUpdate(Direction direction, Tuple updateElement)
void	removeChild(Receiver receiver) removes a receiver

Methods inherited from class org.eclipse.viatra.query.runtime.rete.network.BaseNode

acceptPropagatedTraceInfo, assignTraceInfo, getContainer, getNodeId, getTag, getTraceInfoPatternsEnumerated, getTraceInfos, setTag, toString, toStringCore

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.viatra.query.runtime.rete.network.Supplier

pullInto

Methods inherited from interface org.eclipse.viatra.query.runtime.rete.network.Node

acceptPropagatedTraceInfo, assignTraceInfo, getContainer, getNodeId, getTag, getTraceInfos, setTag

Field Detail

children

protected java.util.List<Receiver> children

Constructor Detail

StandardNode

public StandardNode(ReteContainer reteContainer)

Method Detail

propagateUpdate

protected void propagateUpdate(Direction direction,
                               Tuple updateElement)

appendChild

public void appendChild(Receiver receiver)

Description copied from interface: Supplier

appends a receiver that will continously receive insert and revoke updates from this supplier

Specified by:

appendChild in interface Supplier

removeChild

public void removeChild(Receiver receiver)

Description copied from interface: Supplier

removes a receiver

Specified by:

removeChild in interface Supplier

getReceivers

public java.util.Collection<Receiver> getReceivers()

Description copied from interface: Supplier

lists receivers

Specified by:

getReceivers in interface Supplier

getPulledContents

public java.util.Set<Tuple> getPulledContents()

Description copied from interface: Supplier

Returns the contents of this object in this particular moment. For memoryless nodes, this may involve a costly recomputation of contents.

Intended mainly for debug purposes, therefore does not do flushing. During runtime, flushing may be preferred; see ReteContainer.pullContents(Supplier)

Specified by:

getPulledContents in interface Supplier

constructIndex

public ProjectionIndexer constructIndex(TupleMask mask,
                                        TraceInfo... traces)

Description copied from interface: Supplier

Instantiates (or reuses, depending on implementation) an index according to the given mask. Intended for internal use; clients should invoke through Library instead to enable reusing.

Specified by:

constructIndex in interface Supplier

issueError

protected void issueError(java.lang.String message,
                          java.lang.Exception ex)

Since:

1.6