METHOD_0 ( ) { try { org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . IDENT_2 [ ] data = new org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . IDENT_2 [ ] { new org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 ( 1 , 2 ) , new org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 ( 3 , 4 ) , new org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 ( 5 , 6 ) } ; org . apache . flink . streaming . api . IDENT_0 . source . IDENT_3 < org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 > source = new org . apache . flink . streaming . api . IDENT_0 . source . IDENT_3 < org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 > ( org . apache . flink . api . java . IDENT_4 . IDENT_5 . METHOD_2 ( org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 . class ) . METHOD_3 ( new org . apache . flink . api . common . METHOD_4 ( ) ) , data ) ; java . util . List < org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 > result = new java . util . ArrayList < org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 > ( ) ; source . run ( new org . apache . flink . streaming . api . IDENT_0 . IDENT_6 < org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 > ( result ) ) ; "<AssertPlaceHolder>" ; } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; org . junit . Assert . fail ( e . getMessage ( ) ) ; } } run ( org . apache . flink . streaming . api . IDENT_0 . source . IDENT_7 ) { try { org . apache . flink . metrics . IDENT_8 IDENT_9 = org . apache . flink . streaming . api . IDENT_0 . source . IDENT_10 . METHOD_5 ( ) . METHOD_6 ( ) . METHOD_7 ( STRING_0 ) ; if ( ( IDENT_11 ) && ( ( format ) instanceof org . apache . flink . api . common . io . IDENT_12 ) ) { ( ( org . apache . flink . api . common . io . IDENT_12 ) ( format ) ) . METHOD_8 ( ) ; } IDENT_13 IDENT_14 = serializer . METHOD_9 ( ) ; while ( IDENT_11 ) { format . METHOD_10 ( IDENT_15 . next ( ) ) ; while ( ( IDENT_11 ) && ( ! ( format . METHOD_11 ( ) ) ) ) { IDENT_14 = format . METHOD_12 ( IDENT_14 ) ; if ( IDENT_14 != null ) { ctx . collect ( IDENT_14 ) ; } else { break ; } } format . close ( ) ; IDENT_9 . METHOD_13 ( ) ; if ( IDENT_11 ) { IDENT_11 = IDENT_15 . hasNext ( ) ; } } } finally { format . close ( ) ; if ( ( format ) instanceof org . apache . flink . api . common . io . IDENT_12 ) { ( ( org . apache . flink . api . common . io . IDENT_12 ) ( format ) ) . METHOD_14 ( ) ; } IDENT_11 = false ; } }
org . junit . Assert . assertEquals ( java . util . Arrays . asList ( data ) , result )