METHOD_0 ( ) { final java . lang . String IDENT_0 = STRING_0 ; final org . apache . rya . streams . api . entity . IDENT_1 IDENT_2 = new org . apache . rya . streams . api . entity . METHOD_1 ( java . util . UUID . METHOD_2 ( ) , STRING_1 , true , false ) ; final org . eclipse . IDENT_3 . model . IDENT_4 IDENT_5 = org . eclipse . IDENT_3 . model . impl . IDENT_6 . getInstance ( ) ; final java . util . List < org . apache . rya . api . model . IDENT_7 > IDENT_8 = new java . util . ArrayList ( ) ; IDENT_8 . add ( new org . apache . rya . api . model . METHOD_3 ( IDENT_5 . METHOD_4 ( IDENT_5 . METHOD_5 ( STRING_2 ) , IDENT_5 . METHOD_5 ( STRING_3 ) , IDENT_5 . METHOD_5 ( STRING_0 0 ) ) , "a" ) ) ; IDENT_8 . add ( new org . apache . rya . api . model . METHOD_3 ( IDENT_5 . METHOD_4 ( IDENT_5 . METHOD_5 ( STRING_4 ) , IDENT_5 . METHOD_5 ( STRING_3 ) , IDENT_5 . METHOD_5 ( STRING_5 ) ) , "a" ) ) ; IDENT_8 . add ( new org . apache . rya . api . model . METHOD_3 ( IDENT_5 . METHOD_4 ( IDENT_5 . METHOD_5 ( STRING_6 ) , IDENT_5 . METHOD_5 ( STRING_3 ) , IDENT_5 . METHOD_5 ( STRING_5 ) ) , "a" ) ) ; final java . util . List < org . apache . rya . api . model . IDENT_9 > expected = new java . util . ArrayList ( ) ; org . eclipse . IDENT_3 . query . impl . IDENT_10 IDENT_11 = new org . eclipse . IDENT_3 . query . impl . METHOD_6 ( ) ; IDENT_11 . METHOD_7 ( STRING_0 1 , IDENT_5 . METHOD_5 ( STRING_2 ) ) ; IDENT_11 . METHOD_7 ( STRING_7 , IDENT_5 . METHOD_5 ( STRING_0 0 ) ) ; expected . add ( new org . apache . rya . api . model . METHOD_8 ( IDENT_11 , "a" ) ) ; IDENT_11 = new org . eclipse . IDENT_3 . query . impl . METHOD_6 ( ) ; IDENT_11 . METHOD_7 ( STRING_0 1 , IDENT_5 . METHOD_5 ( STRING_4 ) ) ; IDENT_11 . METHOD_7 ( STRING_7 , IDENT_5 . METHOD_5 ( STRING_5 ) ) ; expected . add ( new org . apache . rya . api . model . METHOD_8 ( IDENT_11 , "a" ) ) ; IDENT_11 = new org . eclipse . IDENT_3 . query . impl . METHOD_6 ( ) ; IDENT_11 . METHOD_7 ( STRING_0 1 , IDENT_5 . METHOD_5 ( STRING_6 ) ) ; IDENT_11 . METHOD_7 ( STRING_7 , IDENT_5 . METHOD_5 ( STRING_5 ) ) ; expected . add ( new org . apache . rya . api . model . METHOD_8 ( IDENT_11 , "a" ) ) ; final org . apache . rya . streams . kafka . IDENT_12 . IDENT_13 IDENT_14 = new org . apache . rya . streams . kafka . IDENT_12 . METHOD_9 ( kafka . METHOD_10 ( ) ) ; final java . lang . String IDENT_15 = ( ( kafka . METHOD_11 ( ) ) + STRING_8 ) + ( kafka . METHOD_12 ( ) ) ; final org . apache . rya . streams . kafka . IDENT_16 IDENT_17 = new org . apache . rya . streams . kafka . METHOD_13 ( IDENT_15 ) ; final org . apache . rya . streams . IDENT_18 . IDENT_19 executor = new org . apache . rya . streams . IDENT_18 . kafka . METHOD_14 ( IDENT_14 , IDENT_17 ) ; executor . METHOD_15 ( ) ; try { executor . METHOD_16 ( IDENT_0 , IDENT_2 ) ; java . lang . Thread . sleep ( INT_0 ) ; final java . lang . String IDENT_20 = org . apache . rya . streams . kafka . IDENT_21 . METHOD_17 ( IDENT_0 ) ; final org . apache . rya . streams . api . IDENT_12 . IDENT_22 IDENT_23 = new org . apache . rya . streams . kafka . IDENT_12 . METHOD_18 ( METHOD_17 , IDENT_24 ) ; IDENT_23 . METHOD_19 ( IDENT_8 ) ; final java . lang . String IDENT_25 = org . apache . rya . streams . kafka . IDENT_21 . METHOD_20 ( IDENT_0 , IDENT_2 . METHOD_21 ( ) ) ; IDENT_26 . METHOD_22 ( com . google . common . collect . Lists . newArrayList ( IDENT_25 ) ) ; final java . util . List < org . apache . rya . api . model . METHOD_8 > results = org . apache . rya . test . kafka . IDENT_27 . METHOD_23 ( INT_1 , 6 , 3 , IDENT_26 ) ; "<AssertPlaceHolder>" ; } finally { executor . METHOD_24 ( ) ; } } METHOD_23 ( int , int , int , org . apache . kafka . IDENT_28 . consumer . IDENT_29 ) { METHOD_25 ( consumer ) ; final java . util . List < IDENT_30 > values = new java . util . ArrayList ( ) ; int i = 0 ; while ( ( ( values . size ( ) ) < IDENT_31 ) && ( i < IDENT_32 ) ) { for ( final org . apache . kafka . IDENT_28 . consumer . IDENT_33 < IDENT_34 , IDENT_30 > record : consumer . METHOD_26 ( IDENT_35 ) ) { values . add ( record . value ( ) ) ; } i ++ ; } return values ; }
org . junit . Assert . assertEquals ( expected , results )