public abstract class TransformerNode extends SingleInputNode
mailbox, parentchildMailboxes, childrennodeId, reteContainer, tag, traceInfos| Constructor and Description |
|---|
TransformerNode(ReteContainer reteContainer) |
| Modifier and Type | Method and Description |
|---|---|
void |
pullInto(java.util.Collection<Tuple> collector,
boolean flush)
Pulls the contents of this object in this particular moment into a target collection.
|
void |
pullIntoWithTimeline(java.util.Map<Tuple,Timeline<Timestamp>> collector,
boolean flush) |
protected abstract Tuple |
transform(Tuple input) |
void |
update(Direction direction,
Tuple updateElement,
Timestamp timestamp)
Updates the receiver with a newly found or lost partial matching.
|
appendParent, assignTraceInfo, getCommunicationTracker, getMailbox, getParents, instantiateMailbox, propagatePullInto, propagatePullIntoWithTimestamp, removeParentappendChild, 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, removeChildbatchUpdateacceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfos, setTagpublic TransformerNode(ReteContainer reteContainer)
public void pullInto(java.util.Collection<Tuple> collector, boolean flush)
Supplierflush - if true, flushing of messages is allowed during the pull, otherwise flushing is not allowedpublic void pullIntoWithTimeline(java.util.Map<Tuple,Timeline<Timestamp>> collector, boolean flush)