METHOD_0 ( ) { java . lang . String IDENT_0 = org . apache . IDENT_1 . common . util . IDENT_2 . METHOD_1 ( ) . toString ( ) ; java . lang . String IDENT_3 = ( ( ( ( org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . IDENT_6 . METHOD_2 ( IDENT_7 ) ) + ( java . io . File . IDENT_8 ) ) + ( org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . IDENT_9 . IDENT_10 ) ) + ( java . io . File . IDENT_8 ) ) + IDENT_0 ; java . lang . String IDENT_11 = ( IDENT_3 + ( java . io . File . IDENT_8 ) ) + STRING_0 ; org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . IDENT_12 builder = new org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . METHOD_3 ( IDENT_13 , new java . lang . String [ ] { STRING_1 } , IDENT_11 ) ; builder . build ( org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . IDENT_9 . METHOD_4 ( INT_0 ) ) ; java . lang . String IDENT_14 = ( IDENT_3 + ( java . io . File . IDENT_8 ) ) + STRING_2 ; com . google . common . io . IDENT_15 . write ( IDENT_16 . IDENT_17 . name ( ) , new java . io . File ( IDENT_14 ) , IDENT_18 . UTF_8 ) ; org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . IDENT_6 cache = org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . IDENT_6 . getInstance ( IDENT_7 ) ; org . apache . IDENT_1 . IDENT_4 . IDENT_5 . IDENT_19 IDENT_20 = new org . apache . IDENT_1 . IDENT_4 . IDENT_5 . METHOD_5 ( ) ; IDENT_20 . METHOD_6 ( org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . IDENT_9 . IDENT_10 ) ; IDENT_20 . METHOD_7 ( IDENT_0 ) ; IDENT_20 . METHOD_8 ( org . apache . IDENT_1 . IDENT_4 . IDENT_5 . cache . IDENT_9 . IDENT_21 ) ; IDENT_20 . METHOD_9 ( new java . lang . String [ ] { STRING_1 } ) ; org . apache . IDENT_1 . IDENT_4 . IDENT_5 . IDENT_22 IDENT_23 = cache . METHOD_10 ( IDENT_13 , IDENT_20 , false ) ; int IDENT_24 = 0 ; for ( java . lang . String [ ] IDENT_25 : IDENT_23 ) { IDENT_24 ++ ; } IDENT_23 . close ( ) ; "<AssertPlaceHolder>" ; } close ( ) { org . apache . IDENT_1 . source . kafka . hadoop . IDENT_26 . log . info ( STRING_3 , ( ( ( ( ( IDENT_27 ) + STRING_4 ) + ( split . METHOD_11 ( ) ) ) + STRING_4 ) + ( IDENT_28 ) ) , IDENT_29 ) ; consumer . close ( ) ; }
org . junit . Assert . assertEquals ( INT_0 , IDENT_24 )