METHOD_0 ( ) { org . apache . hadoop . conf . Configuration conf = new org . apache . hadoop . hdfs . METHOD_1 ( ) ; final int IDENT_0 = 1 ; final int IDENT_1 = IDENT_0 ; final int IDENT_2 = 1 * IDENT_1 ; conf . METHOD_2 ( IDENT_3 . IDENT_4 , IDENT_0 ) ; conf . METHOD_3 ( IDENT_3 . IDENT_5 , IDENT_2 ) ; conf . METHOD_2 ( IDENT_3 . IDENT_6 , IDENT_1 ) ; org . apache . hadoop . hdfs . IDENT_7 cluster = new org . apache . hadoop . hdfs . IDENT_7 . Builder ( conf ) . METHOD_4 ( 1 ) . format ( true ) . build ( ) ; org . apache . hadoop . fs . IDENT_8 fs = cluster . METHOD_5 ( ) ; org . apache . hadoop . hdfs . IDENT_9 IDENT_10 = ( ( org . apache . hadoop . hdfs . IDENT_9 ) ( org . apache . hadoop . fs . IDENT_8 . newInstance ( fs . METHOD_6 ( ) , fs . METHOD_7 ( ) ) ) ) ; try { final int IDENT_11 = 10 ; final int IDENT_12 = 2 ; org . apache . hadoop . fs . Path base = new org . apache . hadoop . fs . Path ( STRING_0 ) ; IDENT_10 . METHOD_8 ( base ) ; for ( int f = 0 ; f < IDENT_11 ; f ++ ) { org . apache . hadoop . hdfs . IDENT_13 out = IDENT_10 . create ( new org . apache . hadoop . fs . Path ( base , ( "test" + f ) ) ) ; for ( int k = 0 ; k < IDENT_12 ; k ++ ) { out . write ( k ) ; } out . close ( ) ; } for ( int f = 0 ; f < IDENT_11 ; f ++ ) { org . apache . hadoop . hdfs . IDENT_14 in = IDENT_10 . METHOD_9 ( new org . apache . hadoop . fs . Path ( base , ( "test" + f ) ) ) ; for ( int k = 0 ; k < IDENT_12 ; k ++ ) { "<AssertPlaceHolder>" ; } in . close ( ) ; } } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; } finally { cluster . METHOD_10 ( ) ; } } read ( ) { if ( ( IDENT_15 ) > 0 ) { try { java . lang . Thread . sleep ( IDENT_16 ) ; } catch ( java . lang . IDENT_17 e ) { } ( IDENT_15 ) OP_0 ; return 1 ; } return - 1 ; }
org . junit . Assert . assertTrue ( ( ( in . read ( ) ) == k ) )