partitionby operation for connected data stream using key expressions . partitions the elements of input1 and input2 according to fields1 and fields2 . a field expression is either the name of a public field or a getter method with parentheses of the datastream s underlying type . a dot can be used to drill down into objects , as in `` field1.getinnerfield2 '' 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 ConnectedStreams<IN1,IN2> keyBy concode_elem_sep ConnectedStreams<IN1,IN2> keyBy concode_elem_sep ConnectedStreams<IN1,IN2> keyBy concode_elem_sep ConnectedStreams<IN1,IN2> keyBy concode_elem_sep ConnectedStreams<IN1,IN2> keyBy concode_elem_sep TypeInformation<IN1> getType1 concode_elem_sep TypeInformation<IN2> getType2 concode_elem_sep SingleOutputStreamOperator<OUT,?> map
ConnectedStreams < IN1 , IN2 > function ( String [ ] arg0 , String [ ] arg1 ) { return new ConnectedStreams < > ( environment , inputStream1 . partitionByHash ( arg0 ) , inputStream2 . partitionByHash ( arg1 ) ) ; }