Interface Receiver

    • Method Detail

      • update

        void update​(Direction direction,
                    Tuple updateElement,
                    Timestamp timestamp)
        Updates the receiver with a newly found or lost partial matching.
        Since:
        2.4
      • batchUpdate

        default void batchUpdate​(java.util.Collection<java.util.Map.Entry<Tuple,​java.lang.Integer>> updates,
                                 Timestamp timestamp)
        Updates the receiver in batch style with a collection of updates. The input collection consists of pairs in the form (t, c) where t is an update tuple and c is the count. The count can also be negative, and it specifies how many times the tuple t gets deleted or inserted. The default implementation of this method simply calls update(Direction, Tuple, Timestamp) individually for all updates.
        Since:
        2.8
      • getMailbox

        Mailbox getMailbox()
        Returns the Mailbox of this receiver.
        Returns:
        the mailbox
        Since:
        2.0
      • appendParent

        void appendParent​(Supplier supplier)
        appends a parent that will continuously send insert and revoke updates to this supplier
      • removeParent

        void removeParent​(Supplier supplier)
        removes a parent
      • getParents

        java.util.Collection<Supplier> getParents()
        access active parent