METHOD_0 ( ) { org . apache . IDENT_0 . IDENT_1 . hdfs . IDENT_2 . LOG . debug ( STRING_0 ) ; final long IDENT_3 = 2 ; final java . lang . String IDENT_4 = STRING_1 ; final long IDENT_5 = 5 ; final long IDENT_6 = 2 ; final int IDENT_7 = 2 ; java . lang . String IDENT_8 = ( IDENT_9 ) + STRING_2 6 ; int i = 1 ; int j = 1 ; org . apache . hadoop . conf . Configuration conf = new org . apache . hadoop . conf . Configuration ( ) ; org . apache . hadoop . fs . IDENT_10 fs = org . apache . hadoop . fs . IDENT_10 . get ( conf ) ; org . apache . hadoop . fs . Path IDENT_11 = new org . apache . hadoop . fs . Path ( IDENT_8 ) ; fs . delete ( IDENT_11 , true ) ; fs . METHOD_1 ( IDENT_11 ) ; org . apache . IDENT_0 . IDENT_1 . hdfs . IDENT_12 IDENT_13 = new org . apache . IDENT_0 . IDENT_1 . hdfs . METHOD_2 ( ) ; IDENT_1 = new org . apache . IDENT_0 . IDENT_1 . hdfs . METHOD_3 ( IDENT_13 ) ; org . apache . IDENT_0 . Context context = new org . apache . IDENT_0 . Context ( ) ; context . put ( STRING_3 , IDENT_8 ) ; context . put ( STRING_2 4 , IDENT_4 ) ; context . put ( STRING_4 , java . lang . String . valueOf ( IDENT_3 ) ) ; context . put ( STRING_2 5 , java . lang . String . valueOf ( IDENT_5 ) ) ; context . put ( STRING_5 , java . lang . String . valueOf ( IDENT_6 ) ) ; context . put ( STRING_2 , METHOD_2 . IDENT_14 ) ; context . put ( STRING_2 3 , java . lang . Long . toString ( 1000 ) ) ; org . apache . IDENT_0 . conf . IDENT_15 . METHOD_4 ( IDENT_1 , context ) ; org . apache . IDENT_0 . IDENT_16 channel = new org . apache . IDENT_0 . channel . METHOD_5 ( ) ; org . apache . IDENT_0 . conf . IDENT_15 . METHOD_4 ( channel , context ) ; IDENT_1 . METHOD_6 ( channel ) ; IDENT_1 . start ( ) ; java . util . Calendar IDENT_17 = java . util . Calendar . getInstance ( ) ; for ( i = 0 ; i < IDENT_7 ; i ++ ) { org . apache . IDENT_0 . IDENT_18 IDENT_19 = channel . METHOD_7 ( ) ; IDENT_19 . METHOD_8 ( ) ; for ( j = 1 ; j <= IDENT_3 ; j ++ ) { org . apache . IDENT_0 . IDENT_20 event = new org . apache . IDENT_0 . event . METHOD_9 ( ) ; IDENT_17 . METHOD_10 ( ) ; IDENT_17 . set ( INT_0 , i , i , i , 0 ) ; event . METHOD_11 ( ) . put ( STRING_2 0 , java . lang . String . valueOf ( IDENT_17 . METHOD_12 ( ) ) ) ; event . METHOD_11 ( ) . put ( STRING_6 , ( STRING_7 + i ) ) ; event . METHOD_11 ( ) . put ( STRING_2 1 , STRING_8 ) ; event . METHOD_13 ( ( ( ( STRING_2 2 + i ) + STRING_9 ) + j ) . getBytes ( ) ) ; channel . put ( event ) ; } IDENT_19 . commit ( ) ; IDENT_19 . close ( ) ; org . apache . IDENT_0 . IDENT_21 . Status IDENT_22 = IDENT_1 . process ( ) ; "<AssertPlaceHolder>" ; } IDENT_1 . METHOD_14 ( ) ; } process ( ) { org . apache . IDENT_0 . IDENT_1 . hbase . Status status = Status . IDENT_23 ; org . apache . IDENT_0 . IDENT_16 channel = METHOD_15 ( ) ; org . apache . IDENT_0 . IDENT_18 IDENT_19 = channel . METHOD_7 ( ) ; java . util . List < org . apache . hadoop . hbase . client . IDENT_24 > IDENT_25 = new java . util . IDENT_26 < org . apache . hadoop . hbase . client . IDENT_24 > ( ) ; java . util . List < org . apache . hadoop . hbase . client . IDENT_27 > IDENT_28 = new java . util . IDENT_26 < org . apache . hadoop . hbase . client . IDENT_27 > ( ) ; IDENT_19 . METHOD_8 ( ) ; for ( long i = 0 ; i < ( IDENT_6 ) ; i ++ ) { org . apache . IDENT_0 . IDENT_20 event = channel . METHOD_16 ( ) ; if ( event == null ) { status = Status . IDENT_29 ; IDENT_30 . METHOD_17 ( STRING_10 ) ; break ; } else { serializer . METHOD_18 ( event , IDENT_31 ) ; IDENT_25 . addAll ( serializer . METHOD_19 ( ) ) ; IDENT_28 . addAll ( serializer . METHOD_20 ( ) ) ; } } METHOD_21 ( IDENT_25 , IDENT_28 , IDENT_19 ) ; return status ; }
org . junit . Assert . assertEquals ( IDENT_22 , Status . IDENT_29 )