METHOD_0 ( ) { final org . apache . rya . api . client . IDENT_0 . IDENT_1 IDENT_2 = METHOD_1 ( ) ; final org . apache . rya . api . client . IDENT_3 IDENT_4 = org . apache . rya . api . client . IDENT_0 . IDENT_5 . build ( IDENT_2 , METHOD_2 ( ) ) ; final org . apache . rya . api . client . IDENT_6 . IDENT_7 IDENT_8 = org . apache . rya . api . client . IDENT_6 . IDENT_7 . builder ( ) . METHOD_3 ( false ) . METHOD_4 ( false ) . METHOD_5 ( false ) . METHOD_6 ( false ) . METHOD_7 ( false ) . METHOD_8 ( false ) . build ( ) ; IDENT_4 . METHOD_9 ( ) . METHOD_10 ( conf . METHOD_11 ( ) , IDENT_8 ) ; final java . util . Set < org . eclipse . IDENT_9 . model . IDENT_10 > IDENT_11 = METHOD_12 ( ) ; IDENT_4 . METHOD_13 ( ) . METHOD_0 ( conf . METHOD_11 ( ) , IDENT_11 ) ; final java . util . Set < org . eclipse . IDENT_9 . model . IDENT_10 > IDENT_12 = new java . util . HashSet ( ) ; final com . mongodb . client . IDENT_13 < org . bson . Document > IDENT_14 = METHOD_2 ( ) . METHOD_14 ( conf . METHOD_11 ( ) ) . METHOD_15 ( conf . METHOD_16 ( ) ) . find ( ) . iterator ( ) ; while ( IDENT_14 . hasNext ( ) ) { final org . bson . Document IDENT_15 = IDENT_14 . next ( ) ; IDENT_12 . add ( org . apache . rya . api . client . IDENT_0 . IDENT_16 . IDENT_17 . METHOD_17 ( org . apache . rya . api . client . IDENT_0 . IDENT_16 . IDENT_17 . METHOD_18 ( IDENT_15 . getString ( STRING_0 ) ) , org . apache . rya . api . client . IDENT_0 . IDENT_16 . IDENT_17 . METHOD_18 ( IDENT_15 . getString ( STRING_1 ) ) , org . apache . rya . api . client . IDENT_0 . IDENT_16 . IDENT_17 . METHOD_18 ( IDENT_15 . getString ( STRING_2 ) ) ) ) ; } "<AssertPlaceHolder>" ; } add ( java . lang . String , boolean , boolean ) { METHOD_19 ( query ) ; IDENT_18 . METHOD_20 ( ) ; try { METHOD_21 ( ) ; final java . util . UUID IDENT_19 = java . util . UUID . METHOD_22 ( ) ; final org . apache . rya . streams . api . IDENT_20 . IDENT_21 IDENT_22 = org . apache . rya . streams . api . IDENT_20 . IDENT_21 . create ( IDENT_19 , query , IDENT_23 , IDENT_24 ) ; IDENT_25 . write ( IDENT_22 ) ; METHOD_23 ( ) ; return IDENT_26 . get ( IDENT_19 ) ; } catch ( final org . apache . rya . streams . api . IDENT_20 . IDENT_27 . IDENT_28 e ) { throw new org . apache . rya . streams . api . IDENT_20 . METHOD_24 ( ( STRING_3 + query ) , e ) ; } finally { METHOD_20 . METHOD_25 ( ) ; } }
org . junit . Assert . assertEquals ( IDENT_11 , IDENT_12 )