METHOD_0 ( ) { java . lang . String IDENT_0 = ( ( ( org . apache . flink . IDENT_1 . IDENT_2 . IDENT_3 ) + "/" ) + ( java . util . UUID . METHOD_1 ( ) ) ) + "/" ; final long [ ] IDENT_4 = new long [ org . apache . flink . IDENT_1 . IDENT_2 . IDENT_5 ] ; final org . apache . flink . IDENT_1 . org . apache . hadoop [ ] IDENT_6 = new org . apache . hadoop . fs . Path [ org . apache . flink . IDENT_1 . IDENT_2 . IDENT_5 ] ; for ( int i = 0 ; i < ( org . apache . flink . IDENT_1 . IDENT_2 . IDENT_5 ) ; i ++ ) { org . apache . flink . api . java . tuple . IDENT_7 < org . apache . hadoop . fs . Path , java . lang . String > file = org . apache . flink . IDENT_1 . IDENT_2 . METHOD_2 ( IDENT_0 , STRING_0 , i , STRING_1 ) ; java . lang . Thread . sleep ( INT_0 ) ; IDENT_6 [ i ] = file . IDENT_8 ; IDENT_4 [ i ] = org . apache . flink . IDENT_1 . IDENT_2 . hdfs . METHOD_3 ( file . IDENT_8 ) . METHOD_4 ( ) ; } org . apache . flink . api . java . io . IDENT_9 format = new org . apache . flink . api . java . io . METHOD_5 ( new org . apache . flink . core . fs . Path ( IDENT_0 ) ) ; format . METHOD_6 ( org . apache . flink . api . common . io . IDENT_10 . METHOD_7 ( ) ) ; org . apache . flink . core . fs . IDENT_11 [ ] IDENT_12 = format . METHOD_8 ( 1 ) ; org . apache . flink . streaming . api . IDENT_13 . source . IDENT_14 < java . lang . String > IDENT_15 = METHOD_9 ( format , IDENT_16 . IDENT_17 ) ; org . apache . flink . IDENT_1 . IDENT_2 . IDENT_18 context = new org . apache . flink . IDENT_1 . IDENT_2 . METHOD_10 ( IDENT_4 ) ; IDENT_15 . METHOD_11 ( new org . apache . flink . configuration . Configuration ( ) ) ; IDENT_15 . run ( context ) ; "<AssertPlaceHolder>" ; for ( int i = 0 ; i < ( org . apache . flink . IDENT_1 . IDENT_2 . IDENT_5 ) ; i ++ ) { org . apache . flink . IDENT_1 . IDENT_2 . hdfs . delete ( IDENT_6 [ i ] , false ) ; } } METHOD_12 ( ) { return IDENT_19 ; }
org . junit . Assert . assertEquals ( IDENT_12 . length , context . METHOD_12 ( ) )