public abstract class AbstractUniquenessEnforcerNode extends StandardNode implements Tunnel
| Modifier and Type | Field and Description |
|---|---|
protected TupleMask |
identityMask |
protected Mailbox |
mailbox |
protected ProjectionIndexer |
memoryIdentityIndexer |
protected ProjectionIndexer |
memoryNullIndexer |
protected TupleMask |
nullMask |
protected java.util.Collection<Supplier> |
parents |
protected java.util.List<SpecializedProjectionIndexer.ListenerSubscription> |
specializedListeners |
protected int |
tupleWidth |
childMailboxes, childrennodeId, reteContainer, tag, traceInfos| Constructor and Description |
|---|
AbstractUniquenessEnforcerNode(ReteContainer reteContainer,
int tupleWidth) |
| Modifier and Type | Method and Description |
|---|---|
void |
appendParent(Supplier supplier)
appends a parent that will continuously send insert and revoke updates to this supplier
|
void |
assignTraceInfo(TraceInfo traceInfo)
assigns new traceability info to this node
|
ProjectionIndexer |
constructIndex(TupleMask mask,
TraceInfo... traces)
Instantiates (or reuses, depending on implementation) an index according to the given mask.
|
abstract ProjectionIndexer |
getIdentityIndexer() |
Mailbox |
getMailbox()
Returns the
Mailbox of this receiver. |
abstract ProjectionIndexer |
getNullIndexer() |
java.util.Collection<Supplier> |
getParents()
access active parent
|
abstract java.util.Set<Tuple> |
getTuples() |
protected abstract Mailbox |
instantiateMailbox() |
protected void |
propagate(Direction direction,
Tuple update,
Timestamp timestamp) |
void |
removeParent(Supplier supplier)
removes a parent
|
appendChild, getChildMailboxes, getPulledContents, getReceivers, issueError, networkStructureChanged, propagateUpdate, removeChildacceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfoPatternsEnumerated, getTraceInfos, setTag, toString, toStringCoreclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitappendChild, getPulledContents, getPulledContents, getReceivers, pullInto, pullIntoWithTimeline, removeChildbatchUpdate, updateacceptPropagatedTraceInfo, getCommunicationTracker, getContainer, getNodeId, getTag, getTraceInfos, setTagprotected final java.util.Collection<Supplier> parents
protected ProjectionIndexer memoryNullIndexer
protected ProjectionIndexer memoryIdentityIndexer
protected final int tupleWidth
protected Mailbox mailbox
protected final TupleMask nullMask
protected final TupleMask identityMask
protected final java.util.List<SpecializedProjectionIndexer.ListenerSubscription> specializedListeners
public AbstractUniquenessEnforcerNode(ReteContainer reteContainer, int tupleWidth)
protected abstract Mailbox instantiateMailbox()
public Mailbox getMailbox()
ReceiverMailbox of this receiver.getMailbox in interface Receiverpublic abstract java.util.Set<Tuple> getTuples()
protected void propagate(Direction direction, Tuple update, Timestamp timestamp)
public ProjectionIndexer constructIndex(TupleMask mask, TraceInfo... traces)
SupplierconstructIndex in interface SupplierconstructIndex in class StandardNodepublic abstract ProjectionIndexer getNullIndexer()
public abstract ProjectionIndexer getIdentityIndexer()
public void appendParent(Supplier supplier)
ReceiverappendParent in interface Receiverpublic void removeParent(Supplier supplier)
ReceiverremoveParent in interface Receiverpublic java.util.Collection<Supplier> getParents()
ReceivergetParents in interface Receiverpublic void assignTraceInfo(TraceInfo traceInfo)
NodeassignTraceInfo in interface NodeassignTraceInfo in class BaseNode