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 ) ) ; int [ ] IDENT_6 = new int [ ] { IDENT_7 . getId ( ) } ; int [ ] IDENT_8 = new int [ ] { IDENT_9 . getId ( ) } ; cc . add ( new de . IDENT_0 . IDENT_1 . IDENT_2 . flink . METHOD_3 ( IDENT_8 , IDENT_6 ) ) ; this . store . METHOD_4 ( ) ; org . apache . flink . api . java . IDENT_10 < org . apache . flink . api . java . tuple . IDENT_11 > IDENT_3 = de . IDENT_0 . IDENT_1 . IDENT_2 . flink . IDENT_12 . IDENT_13 . METHOD_5 ( this . IDENT_14 , this . store , cc , new de . IDENT_0 . IDENT_1 . IDENT_2 . flink . METHOD_6 ( ) ) ; java . util . List < org . apache . flink . api . java . tuple . IDENT_15 < int [ ] , int [ ] > > IDENT_16 = new java . util . ArrayList < org . apache . flink . api . java . tuple . IDENT_15 < int [ ] , int [ ] > > ( ) ; IDENT_3 . output ( new org . apache . flink . api . java . io . METHOD_7 ( IDENT_16 ) ) ; this . IDENT_14 . execute ( STRING_1 ) ; "<AssertPlaceHolder>" ; } execute ( T ) { de . IDENT_0 . IDENT_1 . IDENT_2 . db . query . IDENT_17 . LOGGER . trace ( STRING_2 , this . sql , element ) ; this . IDENT_18 . METHOD_4 ( this . IDENT_19 ) ; METHOD_8 ( ) ; METHOD_9 ( element ) ; long IDENT_20 = java . lang . System . currentTimeMillis ( ) ; java . sql . ResultSet IDENT_21 = this . IDENT_22 . METHOD_10 ( ) ; long IDENT_23 = java . lang . System . currentTimeMillis ( ) ; de . IDENT_0 . IDENT_1 . IDENT_2 . db . query . IDENT_17 . LOGGER . trace ( STRING_3 , ( IDENT_23 - IDENT_20 ) ) ; return IDENT_21 ; }
org . junit . Assert . assertTrue ( ( ( IDENT_16 . size ( ) ) == 1 ) )