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, children
nodeId, 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, removeChild
acceptPropagatedTraceInfo, getContainer, getNodeId, getTag, getTraceInfoPatternsEnumerated, getTraceInfos, setTag, toString, toStringCore
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
appendChild, getPulledContents, getPulledContents, getReceivers, pullInto, pullIntoWithTimeline, removeChild
batchUpdate, update
acceptPropagatedTraceInfo, getCommunicationTracker, getContainer, getNodeId, getTag, getTraceInfos, setTag
protected 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()
Receiver
Mailbox
of this receiver.getMailbox
in interface Receiver
public abstract java.util.Set<Tuple> getTuples()
protected void propagate(Direction direction, Tuple update, Timestamp timestamp)
public ProjectionIndexer constructIndex(TupleMask mask, TraceInfo... traces)
Supplier
constructIndex
in interface Supplier
constructIndex
in class StandardNode
public abstract ProjectionIndexer getNullIndexer()
public abstract ProjectionIndexer getIdentityIndexer()
public void appendParent(Supplier supplier)
Receiver
appendParent
in interface Receiver
public void removeParent(Supplier supplier)
Receiver
removeParent
in interface Receiver
public java.util.Collection<Supplier> getParents()
Receiver
getParents
in interface Receiver
public void assignTraceInfo(TraceInfo traceInfo)
Node
assignTraceInfo
in interface Node
assignTraceInfo
in class BaseNode