METHOD_0 ( ) { final uk . gov . gchq . gaffer . graph . IDENT_0 graph = uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . METHOD_1 ( ) ; final uk . gov . gchq . gaffer . operation . impl . add . IDENT_3 IDENT_4 = new uk . gov . gchq . gaffer . operation . impl . add . IDENT_3 . Builder ( ) . input ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . METHOD_2 ( ) ) . build ( ) ; graph . execute ( IDENT_4 , new uk . gov . gchq . gaffer . user . User ( ) ) ; final uk . gov . gchq . gaffer . operation . impl . get . IDENT_5 IDENT_6 = new uk . gov . gchq . gaffer . operation . impl . get . IDENT_5 . Builder ( ) . build ( ) ; final uk . gov . gchq . gaffer . IDENT_7 . IDENT_8 . IDENT_9 < ? extends uk . gov . gchq . gaffer . data . element . Element > results = graph . execute ( IDENT_6 , new uk . gov . gchq . gaffer . user . User ( ) ) ; final java . util . Set < uk . gov . gchq . gaffer . data . element . Element > IDENT_10 = new java . util . HashSet ( ) ; uk . gov . gchq . gaffer . IDENT_7 . stream . IDENT_11 . METHOD_3 ( results ) . METHOD_4 ( IDENT_10 :: add ) ; final java . util . Set < uk . gov . gchq . gaffer . data . element . Element > IDENT_12 = new java . util . HashSet ( ) ; final uk . gov . gchq . gaffer . data . element . Entity entity = new uk . gov . gchq . gaffer . data . element . Entity ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_13 , STRING_0 ) ; entity . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_14 , STRING_1 ) ; entity . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_15 , uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_16 ) ; IDENT_12 . add ( entity ) ; final uk . gov . gchq . gaffer . data . element . IDENT_17 IDENT_18 = new uk . gov . gchq . gaffer . data . element . IDENT_17 . Builder ( ) . group ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_19 ) . source ( STRING_2 ) . METHOD_6 ( STRING_3 ) . METHOD_7 ( true ) . build ( ) ; IDENT_18 . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_14 , STRING_4 ) ; IDENT_18 . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_15 , ( 2 * ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_16 ) ) ) ; IDENT_12 . add ( IDENT_18 ) ; final uk . gov . gchq . gaffer . data . element . IDENT_17 IDENT_20 = new uk . gov . gchq . gaffer . data . element . IDENT_17 . Builder ( ) . group ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_21 ) . source ( STRING_5 ) . METHOD_6 ( STRING_6 ) . METHOD_7 ( false ) . build ( ) ; IDENT_20 . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_14 , STRING_7 ) ; IDENT_20 . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_22 , STRING_8 ) ; IDENT_20 . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_15 , ( 3 * ( ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_16 ) / 2 ) ) ) ; IDENT_12 . add ( IDENT_20 ) ; final uk . gov . gchq . gaffer . data . element . IDENT_17 IDENT_23 = new uk . gov . gchq . gaffer . data . element . IDENT_17 . Builder ( ) . group ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_21 ) . source ( STRING_5 ) . METHOD_6 ( STRING_6 ) . METHOD_7 ( false ) . build ( ) ; IDENT_23 . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_14 , STRING_7 ) ; IDENT_23 . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_22 , STRING_9 ) ; IDENT_23 . METHOD_5 ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_15 , ( 3 * ( ( uk . gov . gchq . gaffer . IDENT_1 . impl . IDENT_2 . IDENT_16 ) / 2 ) ) ) ; IDENT_12 . add ( IDENT_23 ) ; "<AssertPlaceHolder>" ; } add ( uk . gov . gchq . gaffer . data . element . Element ) { if ( null == element ) { return ; } if ( null == ( queue ) ) { queue = new uk . gov . gchq . gaffer . IDENT_7 . IDENT_8 . METHOD_8 ( IDENT_24 ) ; IDENT_25 = true ; } try { queue . put ( element ) ; } catch ( final java . lang . IDENT_26 e ) { throw new java . lang . RuntimeException ( STRING_10 , e ) ; } if ( ( IDENT_25 ) && ( ! ( queue . isEmpty ( ) ) ) ) { IDENT_25 = false ; store . METHOD_9 ( ( ) -> { try { store . execute ( new uk . gov . gchq . gaffer . operation . impl . add . IDENT_3 . Builder ( ) . input ( queue ) . validate ( validate ) . METHOD_10 ( IDENT_27 ) . build ( ) , new uk . gov . gchq . gaffer . store . Context ( new uk . gov . gchq . gaffer . user . User ( ) ) ) ; IDENT_25 = true ; } catch ( final e ) { throw new < uk . gov . gchq . gaffer . flink . operation . handler . e > java . lang . RuntimeException ( uk . gov . gchq . gaffer . flink . operation . handler . e . getMessage ( ) ) ; } } ) ; } }
org . junit . Assert . assertEquals ( IDENT_12 , IDENT_10 )