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 . apache . rya . streams . api . entity . METHOD_1 IDENT_3 = new org . apache . rya . streams . api . entity . METHOD_1 ( java . util . UUID . METHOD_2 ( ) , STRING_1 , true , false ) ; final org . apache . rya . streams . api . entity . METHOD_1 IDENT_4 = new org . apache . rya . streams . api . entity . METHOD_1 ( java . util . UUID . METHOD_2 ( ) , STRING_1 , true , false ) ; final org . apache . rya . streams . kafka . IDENT_5 IDENT_6 = mock ( org . apache . rya . streams . kafka . IDENT_5 . class ) ; when ( IDENT_6 . METHOD_3 ( eq ( IDENT_0 ) , eq ( IDENT_2 ) ) ) . thenReturn ( mock ( org . apache . kafka . streams . IDENT_7 . class ) ) ; when ( IDENT_6 . METHOD_3 ( eq ( IDENT_0 ) , eq ( IDENT_3 ) ) ) . thenReturn ( mock ( org . apache . kafka . streams . IDENT_7 . class ) ) ; when ( IDENT_6 . METHOD_3 ( eq ( IDENT_0 ) , eq ( IDENT_4 ) ) ) . thenReturn ( mock ( org . apache . kafka . streams . IDENT_7 . class ) ) ; final org . apache . rya . streams . IDENT_8 . IDENT_9 executor = new org . apache . rya . streams . IDENT_8 . kafka . METHOD_4 ( mock ( org . apache . rya . streams . kafka . IDENT_10 . IDENT_11 . class ) , IDENT_6 ) ; executor . METHOD_5 ( ) ; try { executor . METHOD_6 ( IDENT_0 , IDENT_2 ) ; executor . METHOD_6 ( IDENT_0 , IDENT_3 ) ; executor . METHOD_6 ( IDENT_0 , IDENT_4 ) ; final java . util . Set < java . util . UUID > expected = com . google . common . collect . IDENT_12 . METHOD_7 ( IDENT_2 . METHOD_8 ( ) , IDENT_3 . METHOD_8 ( ) , IDENT_4 . METHOD_8 ( ) ) ; "<AssertPlaceHolder>" ; } finally { executor . METHOD_9 ( ) ; } } METHOD_10 ( ) { org . apache . rya . streams . IDENT_8 . kafka . METHOD_4 . IDENT_13 . METHOD_11 ( ) ; METHOD_12 ( ( ( state ( ) ) == ( IDENT_14 . IDENT_15 ) ) , STRING_2 ) ; try { return new java . util . HashSet ( IDENT_16 . METHOD_13 ( ) ) ; } finally { org . apache . rya . streams . IDENT_8 . kafka . METHOD_4 . METHOD_11 . METHOD_14 ( ) ; } }
org . junit . Assert . assertEquals ( expected , executor . METHOD_10 ( ) )