METHOD_0 ( ) { org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . common . query . IDENT_3 . IDENT_4 IDENT_3 = METHOD_1 ( STRING_0 ) ; org . IDENT_0 . common . model . impl . properties . IDENT_5 [ ] IDENT_6 = new org . IDENT_0 . common . model . impl . properties . IDENT_5 [ ] { org . IDENT_0 . common . model . impl . properties . IDENT_5 . create ( INT_0 ) } ; org . IDENT_0 . common . model . impl . properties . IDENT_5 [ ] IDENT_7 = new org . IDENT_0 . common . model . impl . properties . IDENT_5 [ ] { org . IDENT_0 . common . model . impl . properties . IDENT_5 . create ( INT_1 ) } ; org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_11 IDENT_12 = new org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . IDENT_8 . IDENT_9 . IDENT_10 . METHOD_2 ( ) ; IDENT_12 . add ( org . IDENT_0 . common . model . impl . id . IDENT_13 . get ( ) , IDENT_6 ) ; IDENT_12 . add ( org . IDENT_0 . common . model . impl . id . IDENT_13 . get ( ) ) ; IDENT_12 . add ( org . IDENT_0 . common . model . impl . id . IDENT_13 . get ( ) , IDENT_7 ) ; org . apache . flink . api . java . IDENT_14 < org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . IDENT_8 . IDENT_9 . IDENT_10 . METHOD_2 > IDENT_15 = METHOD_3 ( ) . METHOD_4 ( IDENT_12 ) ; org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_16 IDENT_17 = new org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . IDENT_8 . IDENT_9 . IDENT_10 . METHOD_5 ( ) ; IDENT_17 . METHOD_6 ( "a" , IDENT_18 . IDENT_19 , 0 ) ; IDENT_17 . METHOD_6 ( "b" , IDENT_18 . IDENT_19 , 1 ) ; IDENT_17 . METHOD_7 ( "a" , STRING_1 , 0 ) ; IDENT_17 . METHOD_7 ( "b" , STRING_1 , 1 ) ; org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . IDENT_8 . IDENT_9 . IDENT_1 . filter . IDENT_20 filter = new org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . IDENT_8 . IDENT_9 . IDENT_1 . filter . METHOD_8 ( IDENT_15 , IDENT_3 , IDENT_17 ) ; "<AssertPlaceHolder>" ; } evaluate ( ) { return input . METHOD_9 ( new org . IDENT_0 . flink . model . impl . IDENT_1 . IDENT_2 . IDENT_8 . IDENT_9 . IDENT_1 . filter . IDENT_21 . METHOD_10 ( IDENT_3 , IDENT_22 , IDENT_23 ) ) . name ( getName ( ) ) ; }
org . junit . Assert . assertEquals ( IDENT_12 , filter . evaluate ( ) . collect ( ) . get ( 0 ) )