applies a coflatmap transformation on a connectedstreams andmaps the output to a common type . the transformation calls a coflatmapfunction #flatmap1 for each element of the first inputand coflatmapfunction #flatmap2 for each element of the secondinput . each coflatmapfunction call returns any number of elements including none . 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 StreamExecutionEnvironment getExecutionEnvironment concode_elem_sep DataStream<IN1> getFirstInput concode_elem_sep SingleOutputStreamOperator<R> 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<R> map
SingleOutputStreamOperator < R > function ( CoFlatMapFunction < IN1 , IN2 , R > arg0 ) { TypeInformation < R > loc0 = TypeExtractor . getBinaryOperatorReturnType ( arg0 , CoFlatMapFunction . class , false , true , getType1 ( ) , getType2 ( ) , Utils . getCallLocationName ( ) , true ) ; return transform ( "srini_string" , loc0 , new CoStreamFlatMap < > ( inputStream1 . clean ( arg0 ) ) ) ; }