METHOD_0 ( ) { try { for ( int i = 1 ; i <= ( IDENT_0 ) ; i ++ ) { final java . io . IDENT_1 IDENT_2 = METHOD_1 ( ) . write ( ( STRING_0 + i ) ) ; "<AssertPlaceHolder>" ; IDENT_2 . write ( ( ( IDENT_3 ) + i ) . getBytes ( ) ) ; IDENT_2 . close ( ) ; try { java . lang . Thread . sleep ( 10 ) ; } catch ( java . lang . Exception e ) { } } java . io . InputStream IDENT_4 = METHOD_1 ( ) . read ( STRING_1 ) ; System . out . println ( new java . lang . String ( com . google . common . io . IDENT_5 . toByteArray ( IDENT_4 ) , com . google . common . base . IDENT_6 . UTF_8 ) ) ; IDENT_4 . close ( ) ; java . io . InputStream IDENT_7 = METHOD_1 ( ) . read ( STRING_2 ) ; System . out . println ( new java . lang . String ( com . google . common . io . IDENT_5 . toByteArray ( IDENT_7 ) , com . google . common . base . IDENT_6 . UTF_8 ) ) ; IDENT_7 . close ( ) ; METHOD_1 ( ) . delete ( STRING_2 ) ; METHOD_1 ( ) . delete ( STRING_1 ) ; System . out . println ( STRING_3 ) ; for ( java . lang . String s : METHOD_1 ( ) . list ( ) ) { System . out . println ( s ) ; } } catch ( final eu . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_11 e ) { e . printStackTrace ( ) ; } catch ( final java . io . IOException e ) { e . printStackTrace ( ) ; } } write ( java . lang . String ) { final org . apache . hadoop . fs . Path path = METHOD_2 ( IDENT_12 ) ; try { final java . io . IDENT_1 stream = this . IDENT_13 . create ( path , false ) ; if ( eu . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_14 . LOGGER . METHOD_3 ( ) ) { eu . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_14 . LOGGER . debug ( ( STRING_4 + ( METHOD_4 ( path ) ) ) ) ; } return stream ; } catch ( final java . io . IOException ex ) { if ( this . IDENT_13 . exists ( path ) ) { throw new eu . IDENT_8 . IDENT_9 . IDENT_10 . METHOD_5 ( IDENT_12 , STRING_5 ) ; } throw ex ; } }
org . junit . Assert . assertNotNull ( IDENT_2 )