METHOD_0 ( ) { org . IDENT_0 . IDENT_1 . api . IDENT_2 flow = new org . IDENT_0 . IDENT_1 . api . builder . METHOD_1 ( ) . id ( STRING_0 ) . METHOD_2 ( ) . stream ( STRING_1 ) . METHOD_3 ( ) . function ( new org . IDENT_0 . IDENT_1 . api . METHOD_4 ( ) { @ org . IDENT_0 . IDENT_1 . core . IDENT_3 . IDENT_4 . Override public java . util . List < org . IDENT_0 . IDENT_5 . domain . event . IDENT_6 > execute ( org . IDENT_0 . IDENT_5 . domain . event . IDENT_6 event ) { org . IDENT_0 . IDENT_5 . domain . event . IDENT_6 IDENT_7 = new org . IDENT_0 . IDENT_5 . domain . event . METHOD_5 ( event . getId ( ) , event . METHOD_6 ( ) ) ; IDENT_7 . METHOD_7 ( com . google . common . collect . IDENT_8 . METHOD_8 ( event . METHOD_9 ( ) ) ) ; IDENT_7 . put ( new org . IDENT_0 . IDENT_5 . domain . METHOD_10 ( STRING_2 , ( ( int ) ( ( java . lang . Math . random ( ) ) * 10 ) ) ) ) ; return singletonList ( IDENT_7 ) ; } } ) . end ( ) . select ( ) . fields ( STRING_2 ) . end ( ) . METHOD_11 ( ) . METHOD_12 ( STRING_2 , org . IDENT_0 . IDENT_1 . core . IDENT_3 . IDENT_4 . IDENT_9 ) . METHOD_13 ( 10 ) . end ( ) . METHOD_14 ( ) . METHOD_15 ( ) . METHOD_16 ( ) ; IDENT_10 . IDENT_3 . IDENT_11 . IDENT_12 IDENT_13 = METHOD_17 ( flow , 50 ) ; IDENT_10 . IDENT_3 . IDENT_14 conf = new IDENT_10 . IDENT_3 . METHOD_18 ( ) ; conf . METHOD_19 ( 20 ) ; conf . METHOD_20 ( org . IDENT_0 . IDENT_5 . domain . event . METHOD_5 . class , org . IDENT_0 . IDENT_1 . api . IDENT_15 . IDENT_16 . class ) ; conf . METHOD_21 ( false ) ; IDENT_10 . IDENT_3 . IDENT_17 cluster = new IDENT_10 . IDENT_3 . METHOD_22 ( ) ; cluster . METHOD_23 ( "test" , conf , IDENT_13 ) ; while ( ( org . IDENT_0 . IDENT_1 . api . IDENT_3 . IDENT_4 . IDENT_18 . METHOD_24 ( ) . size ( ) ) < INT_0 ) { try { java . lang . Thread . sleep ( 10 ) ; } catch ( java . lang . IDENT_19 e ) { e . printStackTrace ( ) ; } } cluster . METHOD_25 ( ) ; System . out . println ( org . IDENT_0 . IDENT_1 . api . IDENT_3 . IDENT_4 . IDENT_18 . METHOD_24 ( ) ) ; java . lang . Integer count = 0 ; for ( org . IDENT_0 . IDENT_5 . domain . event . IDENT_6 event : org . IDENT_0 . IDENT_1 . api . IDENT_3 . IDENT_4 . IDENT_18 . METHOD_24 ( ) ) { "<AssertPlaceHolder>" ; } } METHOD_24 ( ) { MOD_0 ( org . IDENT_0 . IDENT_1 . api . IDENT_3 . IDENT_4 . IDENT_18 . IDENT_20 ) { return new java . util . ArrayList < org . IDENT_0 . IDENT_5 . domain . event . IDENT_6 > ( org . IDENT_0 . IDENT_1 . api . IDENT_3 . IDENT_4 . IDENT_18 . IDENT_20 ) ; } }
org . junit . Assert . assertEquals ( ( count ++ ) , event . < java . lang . Integer > get ( STRING_2 ) . getValue ( ) )