METHOD_0 ( ) { try { org . apache . flink . runtime . IDENT_0 . IDENT_1 . IDENT_2 < org . apache . flink . api . common . IDENT_3 . IDENT_4 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > , org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > context = new org . apache . flink . runtime . IDENT_0 . IDENT_1 . IDENT_2 < org . apache . flink . api . common . IDENT_3 . IDENT_4 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > , org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > ( ) ; java . util . List < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > data = org . apache . flink . runtime . IDENT_0 . IDENT_1 . IDENT_6 . METHOD_1 ( ) ; org . apache . flink . api . java . IDENT_7 . IDENT_8 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > IDENT_9 = ( ( org . apache . flink . api . java . IDENT_7 . IDENT_8 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > ) ( org . apache . flink . api . java . IDENT_7 . IDENT_10 . METHOD_2 ( data . get ( 0 ) ) ) ) ; org . apache . flink . util . IDENT_11 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > input = org . apache . flink . runtime . util . IDENT_12 . get ( ) ; context . METHOD_3 ( IDENT_13 . IDENT_14 ) ; org . apache . flink . api . common . IDENT_7 . IDENT_15 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > IDENT_16 = IDENT_9 . METHOD_4 ( new int [ ] { 0 } , new boolean [ ] { true } , 0 , new org . apache . flink . api . common . METHOD_5 ( ) ) ; org . apache . flink . runtime . IDENT_0 . IDENT_1 . IDENT_17 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > result = new org . apache . flink . runtime . IDENT_0 . IDENT_1 . IDENT_17 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > ( IDENT_9 . METHOD_6 ( new org . apache . flink . api . common . METHOD_5 ( ) ) ) ; context . METHOD_7 ( input , IDENT_9 . METHOD_6 ( new org . apache . flink . api . common . METHOD_5 ( ) ) ) ; context . METHOD_8 ( IDENT_16 ) ; context . METHOD_9 ( result ) ; org . apache . flink . runtime . IDENT_0 . IDENT_18 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > driver = new org . apache . flink . runtime . IDENT_0 . IDENT_18 < org . apache . flink . api . java . tuple . IDENT_5 < java . lang . String , java . lang . Integer > > ( ) ; driver . METHOD_10 ( context ) ; driver . METHOD_11 ( ) ; driver . run ( ) ; "<AssertPlaceHolder>" ; } catch ( java . lang . Exception e ) { System . err . println ( e . getMessage ( ) ) ; e . printStackTrace ( ) ; org . junit . Assert . fail ( e . getMessage ( ) ) ; } } METHOD_12 ( ) { return list ; }
org . junit . Assert . assertEquals ( 0 , result . METHOD_12 ( ) . size ( ) )