METHOD_0 ( ) { final long IDENT_0 = java . lang . System . currentTimeMillis ( ) ; org . apache . IDENT_1 . IDENT_2 IDENT_3 = new org . apache . IDENT_1 . METHOD_1 ( ) { @ org . apache . IDENT_1 . IDENT_4 . hdfs . Override public long currentTimeMillis ( ) { return IDENT_0 ; } } ; org . apache . IDENT_1 . IDENT_4 . hdfs . IDENT_5 . LOG . debug ( STRING_0 ) ; final java . lang . String IDENT_6 = STRING_1 ; final long IDENT_7 = 5 ; final long IDENT_8 = 2 ; final int IDENT_9 = 4 ; java . lang . String IDENT_10 = ( IDENT_11 ) + STRING_2 ; java . lang . String IDENT_12 = ( ( IDENT_11 ) + STRING_3 ) + ( java . lang . String . valueOf ( ( IDENT_0 / 1000 ) ) ) ; int IDENT_13 = 0 ; int i = 1 ; int j = 1 ; org . apache . hadoop . conf . Configuration conf = new org . apache . hadoop . conf . Configuration ( ) ; org . apache . hadoop . fs . IDENT_14 fs = org . apache . hadoop . fs . IDENT_14 . get ( conf ) ; org . apache . hadoop . fs . Path IDENT_15 = new org . apache . hadoop . fs . Path ( IDENT_12 ) ; fs . delete ( IDENT_15 , true ) ; fs . METHOD_2 ( IDENT_15 ) ; org . apache . IDENT_1 . Context context = new org . apache . IDENT_1 . Context ( ) ; context . put ( STRING_4 , IDENT_10 ) ; context . put ( STRING_2 3 , IDENT_6 ) ; context . put ( STRING_2 4 , java . lang . String . valueOf ( IDENT_7 ) ) ; context . put ( STRING_5 , java . lang . String . valueOf ( IDENT_8 ) ) ; context . put ( STRING_2 0 , java . lang . String . valueOf ( true ) ) ; org . apache . IDENT_1 . conf . IDENT_16 . METHOD_3 ( IDENT_4 , context ) ; org . apache . IDENT_1 . IDENT_17 channel = new org . apache . IDENT_1 . channel . METHOD_4 ( ) ; org . apache . IDENT_1 . conf . IDENT_16 . METHOD_3 ( channel , context ) ; IDENT_4 . METHOD_5 ( channel ) ; IDENT_4 . METHOD_6 ( IDENT_3 ) ; IDENT_4 . start ( ) ; java . util . Calendar IDENT_18 = java . util . Calendar . getInstance ( ) ; java . util . List < java . lang . String > IDENT_19 = com . google . common . collect . Lists . newArrayList ( ) ; for ( i = 1 ; i < IDENT_9 ; i ++ ) { org . apache . IDENT_1 . IDENT_20 IDENT_21 = channel . METHOD_7 ( ) ; IDENT_21 . METHOD_8 ( ) ; for ( j = 1 ; j <= IDENT_8 ; j ++ ) { org . apache . IDENT_1 . IDENT_22 event = new org . apache . IDENT_1 . event . METHOD_9 ( ) ; IDENT_18 . METHOD_10 ( ) ; IDENT_18 . set ( INT_0 , i , i , i , 0 ) ; event . METHOD_11 ( ) . put ( STRING_6 , java . lang . String . valueOf ( IDENT_18 . METHOD_12 ( ) ) ) ; event . METHOD_11 ( ) . put ( STRING_7 , ( STRING_8 + i ) ) ; java . lang . String body = ( ( STRING_2 1 + i ) + STRING_9 ) + j ; event . METHOD_13 ( body . getBytes ( ) ) ; IDENT_19 . add ( body ) ; channel . put ( event ) ; IDENT_13 ++ ; } IDENT_21 . commit ( ) ; IDENT_21 . close ( ) ; IDENT_4 . process ( ) ; } IDENT_4 . METHOD_14 ( ) ; org . apache . hadoop . fs . IDENT_23 [ ] IDENT_24 = fs . METHOD_15 ( IDENT_15 ) ; org . apache . hadoop . fs . Path [ ] IDENT_25 = org . apache . hadoop . fs . IDENT_26 . METHOD_16 ( IDENT_24 ) ; long IDENT_27 = IDENT_13 / IDENT_7 ; if ( ( IDENT_13 OP_0 IDENT_7 ) > 0 ) IDENT_27 ++ ; "<AssertPlaceHolder>" ; METHOD_17 ( fs , conf , IDENT_15 . METHOD_18 ( ) . getPath ( ) , IDENT_6 , IDENT_19 ) ; IDENT_4 . METHOD_6 ( new org . apache . IDENT_1 . METHOD_19 ( ) ) ; } METHOD_14 ( ) { org . apache . IDENT_1 . IDENT_4 . IDENT_28 . IDENT_29 . close ( IDENT_30 , IDENT_31 ) ; super . METHOD_14 ( ) ; }
org . junit . Assert . assertEquals ( ( STRING_2 2 + ( com . google . common . collect . Lists . newArrayList ( IDENT_25 ) ) ) , IDENT_27 , IDENT_25 . length )