Package tools.refinery.interpreter.rete.single

Class SingleInputNode

java.lang.Object

tools.refinery.interpreter.rete.network.BaseNode

tools.refinery.interpreter.rete.network.StandardNode

tools.refinery.interpreter.rete.single.SingleInputNode

All Implemented Interfaces:

NetworkStructureChangeSensitiveNode, Node, Receiver, Supplier, Tunnel

Direct Known Subclasses:

AbstractColumnAggregatorNode, AbstractEvaluatorNode, DiscriminatorBucketNode, DiscriminatorDispatcherNode, FilterNode, RemoteReceiver, RemoteSupplier, RepresentativeElectionNode, TransformerNode, TransitiveClosureNode, TransparentNode

public abstract class SingleInputNode
extends StandardNode
implements Tunnel

Field Summary

Fields

Modifier and Type	Field	Description
protected Mailbox	mailbox
protected Supplier	parent

Fields inherited from class tools.refinery.interpreter.rete.network.StandardNode

childMailboxes, children

Fields inherited from class tools.refinery.interpreter.rete.network.BaseNode

nodeId, reteContainer, tag, traceInfos

Constructor Summary

Constructors

Constructor	Description
SingleInputNode(ReteContainer reteContainer)

Method Summary

Modifier and Type	Method	Description
void	appendParent(Supplier supplier)	appends a parent that will continuously send insert and revoke updates to this supplier
void	assignTraceInfo(TraceInfo traceInfo)	assigns new traceability info to this node
CommunicationTracker	getCommunicationTracker()
Mailbox	getMailbox()	Returns the Mailbox of this receiver.
Collection<Supplier>	getParents()	access active parent
protected Mailbox	instantiateMailbox()	Instantiates the Mailbox of this receiver.
void	propagatePullInto(Collection<Tuple> collector, boolean flush)	To be called by derived classes and ReteContainer.
void	propagatePullIntoWithTimestamp(Map<Tuple,Timeline<Timestamp>> collector, boolean flush)	To be called by derived classes and ReteContainer.
void	removeParent(Supplier supplier)	removes a parent

Methods inherited from class tools.refinery.interpreter.rete.network.StandardNode

appendChild, constructIndex, getChildMailboxes, getPulledContents, getReceivers, issueError, networkStructureChanged, propagateUpdate, removeChild

Methods inherited from class tools.refinery.interpreter.rete.network.BaseNode

acceptPropagatedTraceInfo, 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 tools.refinery.interpreter.rete.network.Node

acceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfos, setTag

Methods inherited from interface tools.refinery.interpreter.rete.network.Receiver

batchUpdate, update

Methods inherited from interface tools.refinery.interpreter.rete.network.Supplier

appendChild, constructIndex, getPulledContents, getPulledContents, getReceivers, pullInto, pullIntoWithTimeline, removeChild

Field Details

parent

protected Supplier parent

mailbox

protected Mailbox mailbox

Since:

1.6

Constructor Details

SingleInputNode

public SingleInputNode(ReteContainer reteContainer)

Method Details

instantiateMailbox

protected Mailbox instantiateMailbox()

Instantiates the Mailbox of this receiver. Subclasses may override this method to provide their own mailbox implementation.

Returns:

the mailbox

Since:

2.0

getCommunicationTracker

public CommunicationTracker getCommunicationTracker()

Specified by:

getCommunicationTracker in interface Node

getMailbox

public Mailbox getMailbox()

Description copied from interface: Receiver

Returns the Mailbox of this receiver.

Specified by:

getMailbox in interface Receiver

Returns:

the mailbox

appendParent

public void appendParent(Supplier supplier)

Description copied from interface: Receiver

appends a parent that will continuously send insert and revoke updates to this supplier

Specified by:

appendParent in interface Receiver

removeParent

public void removeParent(Supplier supplier)

Description copied from interface: Receiver

removes a parent

Specified by:

removeParent in interface Receiver

propagatePullInto

public void propagatePullInto(Collection<Tuple> collector,
 boolean flush)

To be called by derived classes and ReteContainer.

propagatePullIntoWithTimestamp

public void propagatePullIntoWithTimestamp(Map<Tuple,Timeline<Timestamp>> collector,
 boolean flush)

To be called by derived classes and ReteContainer.

getParents

public Collection<Supplier> getParents()

Description copied from interface: Receiver

access active parent

Specified by:

getParents in interface Receiver

assignTraceInfo

public void assignTraceInfo(TraceInfo traceInfo)

Description copied from interface: Node

assigns new traceability info to this node

Specified by:

assignTraceInfo in interface Node

Overrides:

assignTraceInfo in class BaseNode