public class ExternalInputEnumeratorNode extends StandardNode implements Disconnectable, Receiver, IQueryRuntimeContextListener
Contains those tuples that are in the extensional relation identified by the input key, and also conform to the global seed (if any).
| Modifier and Type | Field and Description |
|---|---|
protected Mailbox |
mailbox |
childMailboxes, childrennodeId, reteContainer, tag, traceInfos| Constructor and Description |
|---|
ExternalInputEnumeratorNode(ReteContainer reteContainer) |
| 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 |
connectThroughContext(ReteEngine engine,
IInputKey inputKey,
Tuple globalSeed) |
void |
disconnect()
Disconnects this rete engine component from the underlying model.
|
Tuple |
getGlobalSeed() |
IInputKey |
getInputKey() |
Mailbox |
getMailbox()
Returns the
Mailbox of this receiver. |
java.util.Collection<Supplier> |
getParents()
access active parent
|
protected java.lang.Iterable<Tuple> |
getTuplesInternal() |
protected Mailbox |
instantiateMailbox()
Instantiates the
Mailbox of this receiver. |
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) |
void |
removeParent(Supplier supplier)
removes a parent
|
void |
update(Direction direction,
Tuple updateElement,
Timestamp timestamp)
Updates the receiver with a newly found or lost partial matching.
|
void |
update(IInputKey key,
Tuple update,
boolean isInsertion)
The given tuple was inserted into or removed from the input relation indicated by the given key.
|
appendChild, constructIndex, getChildMailboxes, getPulledContents, getReceivers, issueError, networkStructureChanged, propagateUpdate, removeChildacceptPropagatedTraceInfo, assignTraceInfo, getContainer, getNodeId, getTag, getTraceInfoPatternsEnumerated, getTraceInfos, setTag, toString, toStringCoreclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitbatchUpdateacceptPropagatedTraceInfo, assignTraceInfo, getCommunicationTracker, getContainer, getNodeId, getTag, getTraceInfos, setTaggetPulledContentsprotected final Mailbox mailbox
public ExternalInputEnumeratorNode(ReteContainer reteContainer)
protected Mailbox instantiateMailbox()
Mailbox of this receiver. Subclasses may override this method to provide their own
mailbox implementation.public Mailbox getMailbox()
ReceiverMailbox of this receiver.getMailbox in interface Receiverpublic void connectThroughContext(ReteEngine engine, IInputKey inputKey, Tuple globalSeed)
public void disconnect()
Disconnectabledisconnect in interface Disconnectableprotected java.lang.Iterable<Tuple> getTuplesInternal()
public void pullInto(java.util.Collection<Tuple> collector, boolean flush)
Supplierpublic void pullIntoWithTimeline(java.util.Map<Tuple,Timeline<Timestamp>> collector, boolean flush)
pullIntoWithTimeline in interface Supplierpublic void update(IInputKey key, Tuple update, boolean isInsertion)
IQueryRuntimeContextListenerupdate in interface IQueryRuntimeContextListenerkey - the key identifying the input relation that was updatedupdate - the tuple that was inserted or removedisInsertion - true if it was an insertion, false otherwise.public void update(Direction direction, Tuple updateElement, Timestamp timestamp)
Receiverpublic 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 IInputKey getInputKey()
public Tuple getGlobalSeed()