Class ExternalInputEnumeratorNode

    • Field Detail

      • mailbox

        protected final Mailbox mailbox
        Since:
        1.6
    • Constructor Detail

      • ExternalInputEnumeratorNode

        public ExternalInputEnumeratorNode​(ReteContainer reteContainer)
    • Method Detail

      • instantiateMailbox

        protected Mailbox instantiateMailbox()
        Instantiates the Mailbox of this receiver. Subclasses may override this method to provide their own mailbox implementation.
        Returns:
        the mailbox
        Since:
        2.0
      • connectThroughContext

        public void connectThroughContext​(ReteEngine engine,
                                          IInputKey inputKey,
                                          Tuple globalSeed)
      • disconnect

        public void disconnect()
        Description copied from interface: Disconnectable
        Disconnects this rete engine component from the underlying model. Disconnecting enables the garbage collection mechanisms to dispose of the rete network.
        Specified by:
        disconnect in interface Disconnectable
      • getTuplesInternal

        protected java.lang.Iterable<Tuple> getTuplesInternal()
        Since:
        2.2
      • pullInto

        public void pullInto​(java.util.Collection<Tuple> collector,
                             boolean flush)
        Description copied from interface: Supplier
        Pulls the contents of this object in this particular moment into a target collection.
        Specified by:
        pullInto in interface Supplier
        flush - if true, flushing of messages is allowed during the pull, otherwise flushing is not allowed
      • update

        public void update​(IInputKey key,
                           Tuple update,
                           boolean isInsertion)
        Description copied from interface: IQueryRuntimeContextListener
        The given tuple was inserted into or removed from the input relation indicated by the given key.
        Specified by:
        update in interface IQueryRuntimeContextListener
        Parameters:
        key - the key identifying the input relation that was updated
        update - the tuple that was inserted or removed
        isInsertion - true if it was an insertion, false otherwise.
      • update

        public void update​(Direction direction,
                           Tuple updateElement,
                           Timestamp timestamp)
        Description copied from interface: Receiver
        Updates the receiver with a newly found or lost partial matching.
        Specified by:
        update in interface Receiver
      • appendParent

        public void appendParent​(Supplier supplier)
        Description copied from interface: Receiver
        appends a parent that will continuously send insert and revoke updates to this supplier
        Specified by:
        appendParent in interface Receiver
      • getParents

        public java.util.Collection<Supplier> getParents()
        Description copied from interface: Receiver
        access active parent
        Specified by:
        getParents in interface Receiver
      • getInputKey

        public IInputKey getInputKey()
      • getGlobalSeed

        public Tuple getGlobalSeed()