public class TimelyUniquenessEnforcerNode extends AbstractUniquenessEnforcerNode
Modifier and Type | Field and Description |
---|---|
protected TimelyMemory<Timestamp> |
memory |
identityMask, mailbox, memoryIdentityIndexer, memoryNullIndexer, nullMask, parents, specializedListeners, tupleWidth
childMailboxes, children
nodeId, reteContainer, tag, traceInfos
Constructor and Description |
---|
TimelyUniquenessEnforcerNode(ReteContainer reteContainer,
int tupleWidth) |
Modifier and Type | Method and Description |
---|---|
ProjectionIndexer |
getIdentityIndexer() |
java.util.Collection<Tuple> |
getMemory() |
ProjectionIndexer |
getNullIndexer() |
protected Mailbox |
instantiateMailbox() |
void |
pullIntoWithTimestamp(java.util.Map<Tuple,Timestamp> collector,
boolean flush) |
void |
update(Direction direction,
Tuple update,
Timestamp timestamp)
The output of the production node should be the smallest timestamp for a given tuple.
|
appendParent, assignTraceInfo, constructIndex, getMailbox, getParents, propagate, pullInto, removeParent
appendChild, 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, getPulledContents, getPulledContents, getReceivers, removeChild
acceptPropagatedTraceInfo, getCommunicationTracker, getContainer, getNodeId, getTag, getTraceInfos, setTag
protected final TimelyMemory<Timestamp> memory
public TimelyUniquenessEnforcerNode(ReteContainer reteContainer, int tupleWidth)
protected Mailbox instantiateMailbox()
instantiateMailbox
in class AbstractUniquenessEnforcerNode
public java.util.Collection<Tuple> getMemory()
getMemory
in class AbstractUniquenessEnforcerNode
public void update(Direction direction, Tuple update, Timestamp timestamp)
public void pullIntoWithTimestamp(java.util.Map<Tuple,Timestamp> collector, boolean flush)
public ProjectionIndexer getNullIndexer()
getNullIndexer
in class AbstractUniquenessEnforcerNode
public ProjectionIndexer getIdentityIndexer()
getIdentityIndexer
in class AbstractUniquenessEnforcerNode