public class MemorylessEvaluatorNode extends AbstractEvaluatorNode
coremailbox, parentchildMailboxes, childrennodeId, reteContainer, tag, traceInfos| Constructor and Description |
|---|
MemorylessEvaluatorNode(ReteContainer reteContainer,
EvaluatorCore core) |
| 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) |
void |
update(Direction direction,
Tuple input,
Timestamp timestamp)
Updates the receiver with a newly found or lost partial matching.
|
getReteContainer, prettyPrintTraceInfoPatternList, propagateIterableUpdateappendParent, 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 MemorylessEvaluatorNode(ReteContainer reteContainer, EvaluatorCore core)
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)