Class RelationEvaluatorNode.BatchingReceiver

    • 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.
      • batchUpdate

        public void batchUpdate​(java.util.Collection<java.util.Map.Entry<Tuple,​java.lang.Integer>> updates,
                                Timestamp timestamp)
        Description copied from interface: Receiver
        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 Receiver.update(Direction, Tuple, Timestamp) individually for all updates.