public < KEY > ConnectedStreams < IN1 , IN2 > keyBy ( KeySelector < IN1 , KEY > keySelector1 , KeySelector < IN2 , KEY > keySelector2 , TypeInformation < KEY > keyType ) { return new ConnectedStreams <> ( environment , inputStream1 . keyBy ( keySelector1 , keyType ) , inputStream2 . keyBy ( keySelector2 , keyType ) ) ; }
KeyBy operation for connected data stream . Assigns keys to the elements of input1 and input2 using keySelector1 and keySelector2 with explicit type information for the common key type .