keyby operation for connected data stream . assigns keys to the elements of input1 and input2 according to keyposition1 and keyposition2 . 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<R> flatMap concode_elem_sep StreamExecutionEnvironment getExecutionEnvironment concode_elem_sep DataStream<IN1> getFirstInput concode_elem_sep SingleOutputStreamOperator<R> transform concode_elem_sep TypeInformation<IN1> getType1 concode_elem_sep TypeInformation<IN2> getType2 concode_elem_sep SingleOutputStreamOperator<R> map
ConnectedStreams < IN1 , IN2 > function ( int arg0 , int arg1 ) { return new ConnectedStreams < > ( this . environment , inputStream1 . keyBy ( arg0 ) , inputStream2 . keyBy ( arg1 ) ) ; }