Class TransitiveClosureNode

    • Constructor Detail

      • TransitiveClosureNode

        public TransitiveClosureNode​(ReteContainer reteContainer)
        Create a new transitive closure rete node. Client may optionally call reinitializeWith(Collection) before using the node, instead of inserting the initial set of tuples one by one.
        Parameters:
        reteContainer - the rete container of the node
    • Method Detail

      • reinitializeWith

        public void reinitializeWith​(java.util.Collection<Tuple> tuples)
        Initializes the graph data source with the given collection of tuples.
        Parameters:
        tuples - the initial collection of tuples
      • 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​(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
      • clear

        public void clear()
        Description copied from interface: Clearable
        Clear all partial matchings stored in memory
        Specified by:
        clear in interface Clearable
      • tupleInserted

        public void tupleInserted​(java.lang.Object source,
                                  java.lang.Object target)
        Description copied from interface: ITcObserver
        Used to notify when a tuple is inserted into the transitive closure relation.
        Specified by:
        tupleInserted in interface ITcObserver<java.lang.Object>
        Parameters:
        source - the source of the tuple
        target - the target of the tuple
      • tupleDeleted

        public void tupleDeleted​(java.lang.Object source,
                                 java.lang.Object target)
        Description copied from interface: ITcObserver
        Used to notify when a tuple is deleted from the transitive closure relation.
        Specified by:
        tupleDeleted in interface ITcObserver<java.lang.Object>
        Parameters:
        source - the source of the tuple
        target - the target of the tuple