METHOD_0 ( ) { de . IDENT_0 . IDENT_1 . IDENT_2 . model . IDENT_3 . IDENT_4 < de . IDENT_0 . IDENT_1 . IDENT_2 . flink . IDENT_5 > cc = store . METHOD_1 ( null , de . IDENT_0 . IDENT_1 . IDENT_2 . flink . IDENT_5 . class , store . METHOD_2 ( STRING_0 ) ) ; cc . add ( new de . IDENT_0 . IDENT_1 . IDENT_2 . flink . METHOD_3 ( this . IDENT_6 . getId ( ) , 1 ) ) ; cc . add ( new de . IDENT_0 . IDENT_1 . IDENT_2 . flink . METHOD_3 ( this . IDENT_7 . getId ( ) , 3 ) ) ; this . store . METHOD_4 ( ) ; org . apache . flink . api . java . IDENT_8 < org . apache . flink . api . java . tuple . IDENT_9 > IDENT_3 = de . IDENT_0 . IDENT_1 . IDENT_2 . flink . IDENT_10 . IDENT_11 . METHOD_5 ( this . IDENT_12 , this . store , cc , new de . IDENT_0 . IDENT_1 . IDENT_2 . flink . METHOD_6 ( ) ) ; java . util . List < org . apache . flink . api . java . tuple . IDENT_13 < java . lang . Integer , java . lang . Integer > > IDENT_14 = new java . util . ArrayList ( ) ; IDENT_3 . output ( new org . apache . flink . api . java . io . METHOD_7 ( IDENT_14 ) ) ; this . IDENT_12 . execute ( STRING_1 ) ; "<AssertPlaceHolder>" ; } execute ( T ) { de . IDENT_0 . IDENT_1 . IDENT_2 . db . query . IDENT_15 . LOGGER . trace ( STRING_2 , this . sql , element ) ; this . IDENT_16 . METHOD_4 ( this . IDENT_17 ) ; METHOD_8 ( ) ; METHOD_9 ( element ) ; long IDENT_18 = java . lang . System . currentTimeMillis ( ) ; java . sql . ResultSet IDENT_19 = this . IDENT_20 . METHOD_10 ( ) ; long IDENT_21 = java . lang . System . currentTimeMillis ( ) ; de . IDENT_0 . IDENT_1 . IDENT_2 . db . query . IDENT_15 . LOGGER . trace ( STRING_3 , ( IDENT_21 - IDENT_18 ) ) ; return IDENT_19 ; }
org . junit . Assert . assertTrue ( ( ( IDENT_14 . size ( ) ) == 2 ) )