Class FilterNode

    • Constructor Detail

    • Method Detail

      • check

        public abstract boolean check​(Tuple ps)
        Abstract filtering predicate. Expected to be stateless.
        Parameters:
        ps - the matching to be checked.
        Returns:
        true if and only if the parameter matching is allowed to pass through this node.
      • 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.
        flush - if true, flushing of messages is allowed during the pull, otherwise flushing is not allowed
      • pullIntoWithTimeline

        public void pullIntoWithTimeline​(java.util.Map<Tuple,​Timeline<Timestamp>> collector,
                                         boolean flush)
      • 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.