Class JoinedStreams.Where<KEY>

  • Type Parameters:
    KEY - The type of the key.
    Enclosing class:
    JoinedStreams<T1,​T2>

    @Public
    public class JoinedStreams.Where<KEY>
    extends Object
    Joined streams that have the key for one side defined.
    • Method Detail

      • equalTo

        public JoinedStreams.Where.EqualTo equalTo​(KeySelector<T2,​KEY> keySelector,
                                                   TypeInformation<KEY> keyType)
        Specifies a KeySelector for elements from the second input with explicit type information for the key type.
        Parameters:
        keySelector - The KeySelector to be used for extracting the second input's key for partitioning.
        keyType - The type information describing the key type.