public class RelationEvaluatorNode extends StandardNode implements Supplier, Clearable
Receiver#doesProcessUpdatesInBatch()
and evaluates arbitrary Java
logic represented by an IRelationEvaluator
on the input relations. This is the backing computation node of a
RelationEvaluation
constraint.Modifier and Type | Class and Description |
---|---|
class |
RelationEvaluatorNode.BatchingReceiver |
childMailboxes, children
nodeId, reteContainer, tag, traceInfos
Constructor and Description |
---|
RelationEvaluatorNode(ReteContainer container,
IRelationEvaluator evaluator) |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clear all partial matchings stored in memory
|
void |
connectToParents(java.util.List<Supplier> inputSuppliers) |
void |
networkStructureChanged()
At the time of the invocation, the dependency graph has already been updated.
|
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) |
appendChild, constructIndex, getChildMailboxes, getPulledContents, getReceivers, issueError, propagateUpdate, removeChild
acceptPropagatedTraceInfo, assignTraceInfo, 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, assignTraceInfo, getCommunicationTracker, getContainer, getNodeId, getTag, getTraceInfos, setTag
public RelationEvaluatorNode(ReteContainer container, IRelationEvaluator evaluator)
public void clear()
Clearable
public void connectToParents(java.util.List<Supplier> inputSuppliers)
public void networkStructureChanged()
NetworkStructureChangeSensitiveNode
networkStructureChanged
in interface NetworkStructureChangeSensitiveNode
networkStructureChanged
in class StandardNode
public void pullInto(java.util.Collection<Tuple> collector, boolean flush)
Supplier
public void pullIntoWithTimeline(java.util.Map<Tuple,Timeline<Timestamp>> collector, boolean flush)
pullIntoWithTimeline
in interface Supplier