METHOD_0 ( ) { final org . apache . flink . api . common . IDENT_0 IDENT_1 = new org . apache . flink . api . common . METHOD_1 ( ) ; final org . apache . flink . runtime . IDENT_2 . IDENT_3 IDENT_4 = org . apache . flink . runtime . IDENT_2 . IDENT_3 . METHOD_2 ( ) ; final java . util . concurrent . IDENT_5 < org . apache . flink . api . java . tuple . IDENT_6 < org . apache . flink . runtime . IDENT_7 . types . IDENT_8 , org . apache . flink . api . common . METHOD_1 , org . apache . flink . runtime . IDENT_7 . types . IDENT_9 > > IDENT_10 = new java . util . concurrent . METHOD_3 ( ) ; org . apache . flink . runtime . IDENT_11 . IDENT_12 IDENT_13 = new org . apache . flink . runtime . IDENT_11 . METHOD_4 ( ) . METHOD_5 ( ( IDENT_14 ) -> { IDENT_10 . METHOD_6 ( org . apache . flink . api . java . tuple . IDENT_6 . of ( IDENT_14 . IDENT_15 , IDENT_14 . IDENT_16 , IDENT_14 . IDENT_17 ) ) ; return new org . apache . flink . runtime . IDENT_2 . IDENT_18 . METHOD_3 < > ( ) ; } ) . METHOD_7 ( ) ; try ( org . apache . flink . runtime . IDENT_2 . IDENT_18 . IDENT_19 IDENT_20 = new org . apache . flink . runtime . IDENT_2 . IDENT_18 . METHOD_8 ( org . apache . flink . runtime . IDENT_2 . IDENT_18 . IDENT_21 . IDENT_22 , org . apache . flink . runtime . IDENT_23 . IDENT_24 . METHOD_9 ( ) , org . apache . flink . runtime . IDENT_23 . IDENT_24 . METHOD_9 ( ) , org . apache . flink . runtime . IDENT_23 . IDENT_24 . METHOD_9 ( ) ) ) { org . apache . flink . runtime . IDENT_2 . IDENT_18 . IDENT_25 IDENT_26 = new org . apache . flink . runtime . IDENT_2 . IDENT_18 . METHOD_10 ( ) . build ( ) ; IDENT_20 . start ( IDENT_4 , org . apache . flink . runtime . concurrent . IDENT_27 . METHOD_11 ( ) , IDENT_26 ) ; final org . apache . flink . runtime . IDENT_7 . types . IDENT_28 IDENT_29 = org . apache . flink . runtime . IDENT_7 . types . IDENT_28 . METHOD_2 ( ) ; final org . apache . flink . runtime . IDENT_7 . types . IDENT_9 IDENT_30 = new org . apache . flink . runtime . IDENT_7 . types . METHOD_12 ( ) ; final org . apache . flink . runtime . IDENT_7 . types . IDENT_31 IDENT_32 = new org . apache . flink . runtime . IDENT_7 . types . METHOD_13 ( 1.0 , 100 ) ; final org . apache . flink . runtime . IDENT_7 . types . IDENT_8 IDENT_33 = new org . apache . flink . runtime . IDENT_7 . types . METHOD_14 ( IDENT_29 , 0 ) ; final org . apache . flink . runtime . IDENT_11 . IDENT_34 IDENT_35 = new org . apache . flink . runtime . IDENT_11 . METHOD_15 ( IDENT_33 , IDENT_32 ) ; final org . apache . flink . runtime . IDENT_11 . IDENT_36 IDENT_37 = new org . apache . flink . runtime . IDENT_11 . METHOD_16 ( java . util . Collections . singletonList ( IDENT_35 ) ) ; IDENT_20 . METHOD_17 ( new org . apache . flink . runtime . IDENT_2 . IDENT_38 . METHOD_18 ( IDENT_29 , IDENT_13 ) , IDENT_37 ) ; final java . lang . String IDENT_39 = STRING_0 ; org . apache . flink . runtime . IDENT_2 . IDENT_40 IDENT_41 = new org . apache . flink . runtime . IDENT_2 . METHOD_19 ( IDENT_1 , IDENT_30 , IDENT_32 , IDENT_39 ) ; IDENT_20 . METHOD_20 ( IDENT_41 ) ; "<AssertPlaceHolder>" ; } } get ( ) { return delegate . get ( ) ; }
org . junit . Assert . assertThat ( IDENT_10 . get ( ) , org . hamcrest . Matchers . is ( org . hamcrest . Matchers . equalTo ( org . apache . flink . api . java . tuple . IDENT_6 . of ( IDENT_33 , IDENT_1 , IDENT_30 ) ) ) )