public abstract class SingleInputNode extends StandardNode implements Tunnel
| Modifier and Type | Field and Description |
|---|---|
protected Mailbox |
mailbox |
protected Supplier |
parent |
childMailboxes, childrennodeId, reteContainer, tag, traceInfos| Constructor and Description |
|---|
SingleInputNode(ReteContainer reteContainer) |
| Modifier and Type | Method and 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. |
java.util.Collection<Supplier> |
getParents()
access active parent
|
protected Mailbox |
instantiateMailbox()
Instantiates the
Mailbox of this receiver. |
void |
propagatePullInto(java.util.Collection<Tuple> collector,
boolean flush)
To be called by derived classes and ReteContainer.
|
void |
propagatePullIntoWithTimestamp(java.util.Map<Tuple,Timeline<Timestamp>> collector,
boolean flush)
To be called by derived classes and ReteContainer.
|
void |
removeParent(Supplier supplier)
removes a parent
|
appendChild, constructIndex, getChildMailboxes, getPulledContents, getReceivers, issueError, networkStructureChanged, propagateUpdate, removeChildacceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfoPatternsEnumerated, getTraceInfos, setTag, toString, toStringCoreclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitappendChild, constructIndex, getPulledContents, getPulledContents, getReceivers, pullInto, pullIntoWithTimeline, removeChildbatchUpdate, updateacceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfos, setTagpublic SingleInputNode(ReteContainer reteContainer)
protected Mailbox instantiateMailbox()
Mailbox of this receiver.
Subclasses may override this method to provide their own mailbox implementation.public CommunicationTracker getCommunicationTracker()
getCommunicationTracker in interface Nodepublic Mailbox getMailbox()
ReceiverMailbox of this receiver.getMailbox in interface Receiverpublic void appendParent(Supplier supplier)
ReceiverappendParent in interface Receiverpublic void removeParent(Supplier supplier)
ReceiverremoveParent in interface Receiverpublic void propagatePullInto(java.util.Collection<Tuple> collector, boolean flush)
public void propagatePullIntoWithTimestamp(java.util.Map<Tuple,Timeline<Timestamp>> collector, boolean flush)
public java.util.Collection<Supplier> getParents()
ReceivergetParents in interface Receiverpublic void assignTraceInfo(TraceInfo traceInfo)
NodeassignTraceInfo in interface NodeassignTraceInfo in class BaseNode