Package org.apache.flink.streaming.runtime.operators.windowing

Interface KeyMap.TraversalEvaluator<K,​V>

  • Type Parameters:
    K - The type of the key.
    V - The type of the value.
    Enclosing class:
    KeyMap<K,​V>
    public static interface KeyMap.TraversalEvaluator<K,​V>
    A visitor for a traversal over the union of multiple hash maps. The visitor is called for each key in the union of the maps and all values associated with that key (one per map, but multiple across maps).

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void keyDone()
      Called when the traversal for the current key is complete.
      void nextValue​(V value)
      Called for each value found for the current key.
      void startNewKey​(K key)
      Called whenever the traversal starts with a new key.

    • Method Detail

      • startNewKey

        void startNewKey​(K key)
          throws Exception
        Called whenever the traversal starts with a new key.
        Parameters:
        key - The key traversed.
        Throws:
        Exception - Method forwards all exceptions.

      • nextValue

        void nextValue​(V value)
        throws Exception
        Called for each value found for the current key.
        Parameters:
        value - The next value.
        Throws:
        Exception - Method forwards all exceptions.

      • keyDone

        void keyDone()
      throws Exception
        Called when the traversal for the current key is complete.
        Throws:
        Exception - Method forwards all exceptions.