METHOD_0 ( ) { org . apache . hadoop . mapreduce . IDENT_0 job = org . apache . hadoop . mapreduce . IDENT_0 . getInstance ( ) ; org . apache . hadoop . conf . Configuration conf = job . METHOD_1 ( ) ; job . METHOD_2 ( org . apache . hadoop . streaming . mapreduce . IDENT_1 . class ) ; job . METHOD_3 ( org . apache . hadoop . mapreduce . IDENT_2 . class ) ; conf . set ( STRING_0 , STRING_1 ) ; conf . set ( STRING_2 , STRING_3 ) ; conf . set ( STRING_4 , STRING_5 ) ; job . METHOD_4 ( org . apache . hadoop . streaming . mapreduce . IDENT_3 . class ) ; job . METHOD_5 ( org . apache . hadoop . io . IDENT_4 . class ) ; job . METHOD_6 ( org . apache . hadoop . io . IDENT_4 . class ) ; job . METHOD_7 ( org . apache . hadoop . io . IDENT_4 . class ) ; job . METHOD_8 ( org . apache . hadoop . io . IDENT_4 . class ) ; org . apache . hadoop . mapreduce . lib . input . IDENT_5 . METHOD_9 ( job , new org . apache . hadoop . fs . Path ( STRING_6 ) ) ; IDENT_6 = new org . apache . hadoop . fs . Path ( STRING_7 ) ; fs = org . apache . hadoop . fs . IDENT_7 . get ( conf ) ; if ( fs . exists ( IDENT_6 ) ) { fs . delete ( IDENT_6 , true ) ; } org . apache . hadoop . mapreduce . lib . output . IDENT_8 . METHOD_10 ( job , IDENT_6 ) ; boolean ret = job . METHOD_11 ( true ) ; "<AssertPlaceHolder>" ; METHOD_12 ( ) ; } METHOD_11 ( boolean ) { if ( ( state ) == ( org . apache . hadoop . mapreduce . IDENT_0 . IDENT_9 . IDENT_10 ) ) { METHOD_13 ( ) ; } if ( IDENT_11 ) { METHOD_14 ( ) ; } else { int IDENT_12 = org . apache . hadoop . mapreduce . IDENT_0 . METHOD_15 ( cluster . METHOD_16 ( ) ) ; while ( ! ( METHOD_17 ( ) ) ) { try { java . lang . Thread . sleep ( IDENT_12 ) ; } catch ( java . lang . IDENT_13 IDENT_14 ) { } } } return METHOD_18 ( ) ; }
org . junit . Assert . assertEquals ( true , ret )