public class MemorylessEvaluatorNode extends AbstractEvaluatorNode
core
mailbox, parent
childMailboxes, children
nodeId, 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, propagateIterableUpdate
appendParent, assignTraceInfo, getCommunicationTracker, getMailbox, getParents, instantiateMailbox, propagatePullInto, propagatePullIntoWithTimestamp, removeParent
appendChild, constructIndex, getChildMailboxes, getPulledContents, getReceivers, issueError, networkStructureChanged, propagateUpdate, removeChild
acceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfoPatternsEnumerated, getTraceInfos, setTag, toString, toStringCore
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
appendChild, constructIndex, getPulledContents, getPulledContents, getReceivers, removeChild
acceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfos, setTag
public MemorylessEvaluatorNode(ReteContainer reteContainer, EvaluatorCore core)
public void pullInto(java.util.Collection<Tuple> collector, boolean flush)
Supplier
flush
- 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)