METHOD_0 ( ) { org . apache . IDENT_0 . IDENT_1 . hdfs . IDENT_2 . LOG . debug ( STRING_0 ) ; final java . lang . String IDENT_3 = STRING_1 ; final long IDENT_4 = 5 ; final long IDENT_5 = 2 ; final int IDENT_6 = 2 ; java . lang . String IDENT_7 = ( IDENT_8 ) + STRING_2 5 ; int i = 1 ; int j = 1 ; org . apache . hadoop . conf . Configuration conf = new org . apache . hadoop . conf . Configuration ( ) ; org . apache . hadoop . fs . IDENT_9 fs = org . apache . hadoop . fs . IDENT_9 . get ( conf ) ; org . apache . hadoop . fs . Path IDENT_10 = new org . apache . hadoop . fs . Path ( IDENT_7 ) ; fs . delete ( IDENT_10 , true ) ; fs . METHOD_1 ( IDENT_10 ) ; org . apache . IDENT_0 . IDENT_1 . hdfs . IDENT_11 IDENT_12 = new org . apache . IDENT_0 . IDENT_1 . hdfs . METHOD_2 ( ) ; IDENT_1 = new org . apache . IDENT_0 . IDENT_1 . hdfs . METHOD_3 ( IDENT_12 ) ; org . apache . IDENT_0 . Context context = new org . apache . IDENT_0 . Context ( ) ; context . put ( STRING_3 , IDENT_7 ) ; context . put ( STRING_2 3 , IDENT_3 ) ; context . put ( STRING_2 4 , java . lang . String . valueOf ( IDENT_4 ) ) ; context . put ( STRING_4 , java . lang . String . valueOf ( IDENT_5 ) ) ; context . put ( STRING_5 , METHOD_2 . IDENT_13 ) ; context . put ( STRING_2 2 , java . lang . Long . toString ( 1000 ) ) ; org . apache . IDENT_0 . conf . IDENT_14 . METHOD_4 ( IDENT_1 , context ) ; org . apache . IDENT_0 . IDENT_15 channel = new org . apache . IDENT_0 . channel . METHOD_5 ( ) ; org . apache . IDENT_0 . conf . IDENT_14 . METHOD_4 ( channel , context ) ; IDENT_1 . METHOD_6 ( channel ) ; IDENT_1 . start ( ) ; java . util . Calendar IDENT_16 = java . util . Calendar . getInstance ( ) ; for ( i = 0 ; i < IDENT_6 ; i ++ ) { org . apache . IDENT_0 . IDENT_17 IDENT_18 = channel . METHOD_7 ( ) ; IDENT_18 . METHOD_8 ( ) ; for ( j = 1 ; j <= IDENT_5 ; j ++ ) { org . apache . IDENT_0 . IDENT_19 event = new org . apache . IDENT_0 . event . METHOD_9 ( ) ; IDENT_16 . METHOD_10 ( ) ; IDENT_16 . set ( INT_0 , i , i , i , 0 ) ; event . METHOD_11 ( ) . put ( STRING_6 , java . lang . String . valueOf ( IDENT_16 . METHOD_12 ( ) ) ) ; event . METHOD_11 ( ) . put ( STRING_7 , ( STRING_8 + i ) ) ; event . METHOD_11 ( ) . put ( STRING_2 0 , STRING_9 ) ; event . METHOD_13 ( ( ( ( STRING_2 1 + i ) + STRING_2 ) + j ) . getBytes ( ) ) ; channel . put ( event ) ; } IDENT_18 . commit ( ) ; IDENT_18 . close ( ) ; org . apache . IDENT_0 . IDENT_20 . Status IDENT_21 = IDENT_1 . process ( ) ; "<AssertPlaceHolder>" ; } IDENT_1 . METHOD_14 ( ) ; } process ( ) { if ( null == ( IDENT_22 ) ) { try { if ( org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . METHOD_15 ( ) ) org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . info ( ( ( ( ( ( this . getName ( ) ) + STRING_10 ) + ( IDENT_25 . METHOD_16 ( ) ) ) + STRING_11 ) + ( IDENT_25 . METHOD_17 ( ) ) ) ) ; IDENT_22 = IDENT_25 . METHOD_18 ( ) ; IDENT_26 . METHOD_19 ( IDENT_27 . IDENT_28 ) ; IDENT_29 = null ; } catch ( java . lang . Exception ex ) { if ( org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . METHOD_20 ( ) ) org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . error ( ( ( this . getName ( ) ) + STRING_12 ) , ex ) ; METHOD_21 ( ) ; return Status . IDENT_30 ; } } if ( null == ( IDENT_29 ) ) { try { if ( org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . METHOD_15 ( ) ) org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . info ( ( ( this . getName ( ) ) + STRING_13 ) ) ; IDENT_29 = IDENT_22 . METHOD_22 ( ) ; IDENT_26 . METHOD_19 ( IDENT_27 . IDENT_31 ) ; if ( org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . METHOD_15 ( ) ) org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . info ( ( ( ( ( ( this . getName ( ) ) + STRING_14 ) + ( IDENT_25 . METHOD_16 ( ) ) ) + STRING_11 ) + ( IDENT_25 . METHOD_17 ( ) ) ) ) ; } catch ( java . lang . Exception ex ) { if ( org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . METHOD_20 ( ) ) org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . error ( ( ( this . getName ( ) ) + STRING_15 ) , ex ) ; METHOD_21 ( ) ; return Status . IDENT_30 ; } } org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_17 tx = METHOD_23 ( ) . METHOD_7 ( ) ; try { tx . METHOD_8 ( ) ; org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_19 e = METHOD_23 ( ) . METHOD_24 ( ) ; if ( e == null ) { tx . METHOD_25 ( ) ; return Status . IDENT_30 ; } try { IDENT_29 . METHOD_26 ( IDENT_32 , IDENT_33 , null , e . METHOD_27 ( ) ) ; tx . commit ( ) ; IDENT_26 . METHOD_19 ( IDENT_27 . IDENT_34 ) ; } catch ( java . lang . Exception ex ) { METHOD_21 ( ) ; throw ex ; } return Status . IDENT_35 ; } catch ( java . lang . Exception ex ) { tx . METHOD_25 ( ) ; if ( org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . METHOD_20 ( ) ) org . apache . IDENT_0 . IDENT_1 . IDENT_23 . IDENT_24 . log . error ( ( ( this . getName ( ) ) + STRING_16 ) , ex ) ; return Status . IDENT_30 ; } finally { tx . close ( ) ; } }
org . junit . Assert . assertEquals ( IDENT_21 , Status . IDENT_30 )