METHOD_0 ( ) { final org . apache . flink . api . java . IDENT_0 IDENT_1 = org . apache . flink . api . java . IDENT_0 . METHOD_1 ( ) ; if ( IDENT_2 ) { IDENT_1 . METHOD_2 ( ) . METHOD_3 ( ) ; } else { IDENT_1 . METHOD_2 ( ) . METHOD_4 ( ) ; } org . apache . flink . api . java . IDENT_3 < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > input = IDENT_1 . METHOD_5 ( org . apache . flink . test . IDENT_5 . IDENT_6 . IDENT_7 ) ; org . apache . flink . api . java . IDENT_3 < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > result = input . METHOD_6 ( 0 ) . METHOD_7 ( new org . apache . flink . api . common . IDENT_8 . IDENT_9 < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > , org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > ( ) { @ org . apache . flink . test . IDENT_5 . Override public void METHOD_8 ( java . lang . IDENT_10 < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > values , org . apache . flink . util . IDENT_11 < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > out ) { java . util . List < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > list = new java . util . ArrayList ( ) ; for ( org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > val : values ) { list . add ( val ) ; } for ( org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > val : list ) { out . collect ( val ) ; } } } ) ; java . util . List < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > is = result . collect ( ) ; java . util . Collections . METHOD_9 ( is , new org . apache . flink . test . IDENT_5 . IDENT_12 < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > ( ) ) ; java . util . List < org . apache . flink . api . java . tuple . IDENT_4 < java . lang . String , java . lang . Integer > > expected = ( IDENT_1 . METHOD_2 ( ) . METHOD_10 ( ) ) ? java . util . Arrays . asList ( new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 4 ) , new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 4 ) , new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 5 ) , new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 5 ) , new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 5 ) ) : java . util . Arrays . asList ( new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 1 ) , new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 2 ) , new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 3 ) , new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 4 ) , new org . apache . flink . api . java . tuple . METHOD_11 ( "a" , 5 ) ) ; "<AssertPlaceHolder>" ; } METHOD_10 ( ) { return IDENT_2 ; }
org . junit . Assert . assertEquals ( expected , is )