Class DiscriminatorDispatcherNode

    • Constructor Detail

      • DiscriminatorDispatcherNode

        public DiscriminatorDispatcherNode​(ReteContainer reteContainer,
                                           int discriminationColumnIndex)
        Parameters:
        reteContainer -
    • Method Detail

      • 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
      • getDiscriminationColumnIndex

        public int getDiscriminationColumnIndex()
      • 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
      • pullIntoFiltered

        public void pullIntoFiltered​(java.util.Collection<Tuple> collector,
                                     java.lang.Object bucketKey,
                                     boolean flush)
        Since:
        2.3
      • pullIntoWithTimestampFiltered

        public void pullIntoWithTimestampFiltered​(java.util.Map<Tuple,​Timeline<Timestamp>> collector,
                                                  java.lang.Object bucketKey,
                                                  boolean flush)
        Since:
        2.3
      • appendChild

        public void appendChild​(Receiver receiver)
        Description copied from interface: Supplier
        appends a receiver that will continously receive insert and revoke updates from this supplier
        Specified by:
        appendChild in interface Supplier
        Overrides:
        appendChild in class StandardNode
      • getBucketMailboxes

        public java.util.Map<java.lang.Object,​Mailbox> getBucketMailboxes()
        Since:
        2.2
      • toStringCore

        protected java.lang.String toStringCore()
        Description copied from class: BaseNode
        clients should override this to append before the tag / trace indicators
        Overrides:
        toStringCore in class BaseNode