METHOD_0 ( ) { info . IDENT_0 . kafka . unit . IDENT_1 IDENT_2 = IDENT_3 . METHOD_1 ( ) ; java . lang . String IDENT_4 = STRING_0 2 ; IDENT_2 . METHOD_2 ( IDENT_4 , 1 ) ; java . lang . String [ ] IDENT_5 = STRING_0 FLOAT_0 split ( STRING_1 ) ; for ( java . lang . String IDENT_6 : IDENT_5 ) { IDENT_2 . METHOD_3 ( new kafka . IDENT_7 . IDENT_8 < java . lang . String , java . lang . String > ( IDENT_4 , IDENT_6 ) ) ; } org . apache . hadoop . conf . Configuration conf = new org . apache . hadoop . conf . Configuration ( false ) ; conf . METHOD_4 ( this . getClass ( ) . getResourceAsStream ( STRING_0 ) ) ; conf . set ( STRING_2 , IDENT_4 ) ; conf . set ( STRING_3 , ( STRING_4 + ( IDENT_9 ) ) ) ; conf . set ( STRING_5 , "1" ) ; conf . set ( STRING_6 , STRING_7 ) ; conf . set ( STRING_0 3 , org . apache . IDENT_10 . examples . IDENT_11 . IDENT_12 . IDENT_13 ) ; conf . set ( STRING_8 , org . apache . IDENT_10 . examples . IDENT_11 . IDENT_12 . IDENT_14 ) ; org . apache . IDENT_10 . api . IDENT_15 < ? > IDENT_16 = org . apache . IDENT_10 . api . IDENT_17 . METHOD_5 ( IDENT_18 . IDENT_19 ) ; com . IDENT_20 . api . IDENT_21 . IDENT_22 IDENT_23 = new com . IDENT_20 . api . IDENT_21 . IDENT_22 . METHOD_6 ( ) ; IDENT_23 . put ( IDENT_15 . IDENT_24 , true ) ; org . apache . IDENT_10 . api . IDENT_17 . IDENT_25 IDENT_26 = IDENT_16 . METHOD_7 ( new org . apache . IDENT_10 . examples . IDENT_11 . METHOD_8 ( ) , conf , IDENT_23 ) ; java . util . HashSet < java . lang . String > IDENT_27 = com . google . common . collect . IDENT_28 . METHOD_9 ( IDENT_5 ) ; java . sql . IDENT_29 IDENT_30 = java . sql . IDENT_31 . METHOD_10 ( org . apache . IDENT_10 . examples . IDENT_11 . IDENT_12 . IDENT_14 ) ; java . sql . IDENT_32 stmt = IDENT_30 . METHOD_11 ( ) ; int IDENT_33 = 0 ; long IDENT_34 = ( java . lang . System . currentTimeMillis ( ) ) + INT_0 ; while ( ( IDENT_33 < ( IDENT_27 . size ( ) ) ) && ( IDENT_34 > ( java . lang . System . currentTimeMillis ( ) ) ) ) { java . lang . Thread . sleep ( INT_1 ) ; java . lang . String IDENT_35 = STRING_0 4 + ( org . apache . IDENT_10 . examples . IDENT_11 . IDENT_12 . IDENT_36 ) ; java . sql . ResultSet IDENT_37 = stmt . METHOD_12 ( IDENT_35 ) ; IDENT_37 . next ( ) ; IDENT_33 = IDENT_37 . METHOD_13 ( 1 ) ; IDENT_37 . close ( ) ; org . apache . IDENT_10 . examples . IDENT_11 . IDENT_12 . LOG . info ( STRING_0 0 , org . apache . IDENT_10 . examples . IDENT_11 . IDENT_12 . IDENT_36 , IDENT_33 ) ; } "<AssertPlaceHolder>" ; IDENT_26 . METHOD_14 ( IDENT_38 . IDENT_39 ) ; } size ( ) { return key . length ; }
org . junit . Assert . assertEquals ( STRING_0 1 , IDENT_27 . size ( ) , IDENT_33 )