METHOD_0 ( ) { org . apache . IDENT_0 . IDENT_1 . hdfs . IDENT_2 . LOG . debug ( STRING_0 ) ; org . apache . IDENT_0 . Context context = new org . apache . IDENT_0 . Context ( ) ; org . apache . IDENT_0 . IDENT_3 channel = new org . apache . IDENT_0 . channel . METHOD_1 ( ) ; context . put ( STRING_1 , IDENT_4 ) ; context . put ( STRING_2 , STRING_3 ) ; org . apache . IDENT_0 . conf . IDENT_5 . METHOD_2 ( IDENT_1 , context ) ; org . apache . IDENT_0 . conf . IDENT_5 . METHOD_2 ( channel , context ) ; IDENT_1 . METHOD_3 ( channel ) ; IDENT_1 . start ( ) ; "<AssertPlaceHolder>" ; IDENT_1 . METHOD_4 ( ) ; } process ( ) { org . apache . IDENT_0 . IDENT_1 . hbase . Status status = Status . IDENT_6 ; org . apache . IDENT_0 . IDENT_3 channel = METHOD_5 ( ) ; org . apache . IDENT_0 . IDENT_7 IDENT_8 = channel . METHOD_6 ( ) ; java . util . List < org . apache . hadoop . hbase . client . IDENT_9 > IDENT_10 = new java . util . IDENT_11 < org . apache . hadoop . hbase . client . IDENT_9 > ( ) ; java . util . List < org . apache . hadoop . hbase . client . IDENT_12 > IDENT_13 = new java . util . IDENT_11 < org . apache . hadoop . hbase . client . IDENT_12 > ( ) ; IDENT_8 . METHOD_7 ( ) ; for ( long i = 0 ; i < ( IDENT_14 ) ; i ++ ) { org . apache . IDENT_0 . IDENT_15 event = channel . METHOD_8 ( ) ; if ( event == null ) { status = Status . IDENT_16 ; IDENT_17 . METHOD_9 ( STRING_4 ) ; break ; } else { serializer . METHOD_10 ( event , IDENT_18 ) ; IDENT_10 . addAll ( serializer . METHOD_11 ( ) ) ; IDENT_13 . addAll ( serializer . METHOD_12 ( ) ) ; } } METHOD_13 ( IDENT_10 , IDENT_13 , IDENT_8 ) ; return status ; }
org . junit . Assert . assertEquals ( Status . IDENT_16 , IDENT_1 . process ( ) )