keyby operation for connected data stream . assigns keys to the elements of input1 and input2 using keyselector1 and keyselector2 . concode_field_sep StreamExecutionEnvironment environment concode_elem_sep DataStream<IN2> inputStream2 concode_elem_sep DataStream<IN1> inputStream1 concode_field_sep DataStream<IN2> getSecondInput concode_elem_sep SingleOutputStreamOperator<OUT,?> flatMap concode_elem_sep StreamExecutionEnvironment getExecutionEnvironment concode_elem_sep DataStream<IN1> getFirstInput concode_elem_sep SingleOutputStreamOperator<OUT,?> transform concode_elem_sep TypeInformation<IN1> getType1 concode_elem_sep TypeInformation<IN2> getType2 concode_elem_sep SingleOutputStreamOperator<OUT,?> map concode_elem_sep ConnectedStreams<IN1,IN2> partitionByHash concode_elem_sep ConnectedStreams<IN1,IN2> partitionByHash concode_elem_sep ConnectedStreams<IN1,IN2> partitionByHash concode_elem_sep ConnectedStreams<IN1,IN2> partitionByHash concode_elem_sep ConnectedStreams<IN1,IN2> partitionByHash
ConnectedStreams < IN1 , IN2 > function ( KeySelector < IN1 , ? > arg0 , KeySelector < IN2 , ? > arg1 ) { return new ConnectedStreams < > ( environment , inputStream1 . keyBy ( arg0 ) , inputStream2 . keyBy ( arg1 ) ) ; }