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