public class DiscriminatorDispatcherNode extends SingleInputNode
DiscriminatorBucketNode
),
based on the value of a given column.
Tuple contents and bucket keys have already been wrapped using IQueryRuntimeContext.wrapElement(Object)
mailbox, parent
children
communicationTracker, nodeId, reteContainer, tag, traceInfos
Constructor and Description |
---|
DiscriminatorDispatcherNode(ReteContainer reteContainer,
int discriminationColumnIndex) |
Modifier and Type | Method and Description |
---|---|
void |
appendChild(Receiver receiver)
appends a receiver that will continously receive insert and revoke updates from this supplier
|
int |
getDiscriminationColumnIndex() |
void |
pullInto(java.util.Collection<Tuple> collector)
pulls the contents of this object in this particular moment into a target collection
|
void |
pullIntoFiltered(java.util.Collection<Tuple> collector,
java.lang.Object bucketKey) |
void |
removeChild(Receiver receiver)
removes a receiver
|
protected java.lang.String |
toStringCore()
clients should override this to append before the tag / trace indicators
|
void |
update(Direction direction,
Tuple updateElement)
updates the receiver with a newly found or lost partial matching
|
appendParent, assignTraceInfo, getMailbox, getParents, instantiateMailbox, propagatePullInto, removeParent
constructIndex, getPulledContents, getReceivers, issueError, propagateUpdate
acceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfoPatternsEnumerated, getTraceInfos, setTag, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
constructIndex, getPulledContents, getReceivers
acceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfos, setTag
public DiscriminatorDispatcherNode(ReteContainer reteContainer, int discriminationColumnIndex)
reteContainer
- public void update(Direction direction, Tuple updateElement)
Receiver
public int getDiscriminationColumnIndex()
public void pullInto(java.util.Collection<Tuple> collector)
Supplier
public void pullIntoFiltered(java.util.Collection<Tuple> collector, java.lang.Object bucketKey)
public void appendChild(Receiver receiver)
Supplier
appendChild
in interface Supplier
appendChild
in class StandardNode
public void removeChild(Receiver receiver)
Supplier
removeChild
in interface Supplier
removeChild
in class StandardNode
protected java.lang.String toStringCore()
BaseNode
toStringCore
in class BaseNode