METHOD_0 ( ) { final org . apache . rya . mongodb . IDENT_0 dao = new org . apache . rya . mongodb . METHOD_1 ( ) ; try { dao . METHOD_2 ( conf ) ; dao . init ( ) ; final org . apache . rya . api . domain . IDENT_1 . IDENT_2 builder = new org . apache . rya . api . domain . IDENT_1 . METHOD_3 ( ) ; builder . METHOD_4 ( new org . apache . rya . api . domain . METHOD_5 ( STRING_0 ) ) ; builder . METHOD_6 ( new org . apache . rya . api . domain . METHOD_5 ( STRING_1 ) ) ; builder . METHOD_7 ( new org . apache . rya . api . domain . METHOD_5 ( STRING_2 ) ) ; final com . mongodb . client . IDENT_3 db = conf . METHOD_8 ( ) . METHOD_9 ( conf . get ( IDENT_4 . IDENT_5 ) ) ; final com . mongodb . client . IDENT_6 < org . bson . Document > IDENT_7 = db . METHOD_10 ( conf . METHOD_11 ( ) ) ; dao . add ( builder . build ( ) ) ; "<AssertPlaceHolder>" ; } finally { dao . METHOD_12 ( ) ; } } count ( ) { final java . lang . String IDENT_8 = STRING_3 + ( ( STRING_3 5 + STRING_4 ) + STRING_3 2 ) ; final org . eclipse . IDENT_9 . model . IDENT_10 IDENT_11 = org . eclipse . IDENT_9 . model . impl . IDENT_12 . getInstance ( ) ; final java . util . List < org . apache . rya . api . model . IDENT_13 > IDENT_14 = new java . util . ArrayList ( ) ; IDENT_14 . add ( new org . apache . rya . api . model . METHOD_13 ( IDENT_11 . METHOD_14 ( IDENT_11 . METHOD_15 ( STRING_3 3 ) , IDENT_11 . METHOD_15 ( STRING_5 ) , IDENT_11 . METHOD_16 ( STRING_6 ) ) , "a" ) ) ; IDENT_14 . add ( new org . apache . rya . api . model . METHOD_13 ( IDENT_11 . METHOD_14 ( IDENT_11 . METHOD_15 ( STRING_3 4 ) , IDENT_11 . METHOD_15 ( STRING_5 ) , IDENT_11 . METHOD_16 ( STRING_6 ) ) , "" ) ) ; IDENT_14 . add ( new org . apache . rya . api . model . METHOD_13 ( IDENT_11 . METHOD_14 ( IDENT_11 . METHOD_15 ( STRING_3 3 ) , IDENT_11 . METHOD_15 ( STRING_5 ) , IDENT_11 . METHOD_16 ( STRING_7 ) ) , "b" ) ) ; final java . util . Set < org . apache . rya . api . model . IDENT_15 > expected = new java . util . HashSet ( ) ; org . eclipse . IDENT_9 . query . impl . IDENT_16 IDENT_17 = new org . eclipse . IDENT_9 . query . impl . METHOD_17 ( ) ; IDENT_17 . METHOD_18 ( STRING_3 6 , IDENT_11 . METHOD_15 ( STRING_3 3 ) ) ; IDENT_17 . METHOD_18 ( STRING_8 , IDENT_11 . METHOD_16 ( STRING_3 0 , IDENT_18 . IDENT_19 ) ) ; expected . add ( new org . apache . rya . api . model . METHOD_19 ( IDENT_17 , "a" ) ) ; IDENT_17 = new org . eclipse . IDENT_9 . query . impl . METHOD_17 ( ) ; IDENT_17 . METHOD_18 ( STRING_3 6 , IDENT_11 . METHOD_15 ( STRING_3 4 ) ) ; IDENT_17 . METHOD_18 ( STRING_8 , IDENT_11 . METHOD_16 ( STRING_3 0 , IDENT_18 . IDENT_19 ) ) ; expected . add ( new org . apache . rya . api . model . METHOD_19 ( IDENT_17 , "" ) ) ; IDENT_17 = new org . eclipse . IDENT_9 . query . impl . METHOD_17 ( ) ; IDENT_17 . METHOD_18 ( STRING_3 6 , IDENT_11 . METHOD_15 ( STRING_3 3 ) ) ; IDENT_17 . METHOD_18 ( STRING_8 , IDENT_11 . METHOD_16 ( STRING_3 1 , IDENT_18 . IDENT_19 ) ) ; expected . add ( new org . apache . rya . api . model . METHOD_19 ( IDENT_17 , STRING_9 ) ) ; final java . lang . String IDENT_20 = java . util . UUID . METHOD_20 ( ) . toString ( ) ; final java . util . UUID IDENT_21 = java . util . UUID . METHOD_20 ( ) ; final java . lang . String IDENT_22 = org . apache . rya . streams . kafka . IDENT_23 . METHOD_21 ( IDENT_20 ) ; final java . lang . String IDENT_24 = org . apache . rya . streams . kafka . IDENT_23 . METHOD_22 ( IDENT_20 , IDENT_21 ) ; final org . apache . kafka . streams . processor . IDENT_25 builder = new org . apache . rya . streams . kafka . IDENT_26 . METHOD_23 ( ) . build ( IDENT_8 , METHOD_21 , IDENT_24 , new org . apache . rya . api . function . IDENT_27 . METHOD_24 ( ) ) ; org . apache . rya . streams . kafka . IDENT_28 . METHOD_25 ( kafka , METHOD_21 , IDENT_24 , builder , IDENT_14 , expected , org . apache . rya . streams . kafka . serialization . IDENT_29 . class ) ; }
org . junit . Assert . assertEquals ( IDENT_7 . count ( ) , 1 )