METHOD_0 ( ) { org . apache . flink . streaming . api . IDENT_0 . IDENT_1 IDENT_2 = org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 ( ) ; org . apache . flink . streaming . api . IDENT_3 . IDENT_4 < org . apache . flink . IDENT_5 . IDENT_6 > input = IDENT_2 . METHOD_2 ( new org . apache . flink . IDENT_5 . METHOD_3 ( 1 , STRING_0 , 1.0 ) , new org . apache . flink . IDENT_5 . METHOD_3 ( 2 , STRING_1 , 2.0 ) , new org . apache . flink . IDENT_5 . METHOD_3 ( 3 , STRING_2 , FLOAT_0 ) , new org . apache . flink . IDENT_5 . METHOD_3 ( 4 , STRING_0 , FLOAT_1 ) , new org . apache . flink . IDENT_5 . METHOD_3 ( 5 , STRING_1 , FLOAT_2 ) , new org . apache . flink . IDENT_5 . METHOD_3 ( 6 , STRING_2 , FLOAT_3 ) ) ; org . apache . flink . IDENT_5 . pattern . IDENT_7 < org . apache . flink . IDENT_5 . METHOD_3 , ? > pattern = org . apache . flink . IDENT_5 . pattern . IDENT_7 . < org . apache . flink . IDENT_5 . METHOD_3 > METHOD_4 ( STRING_0 ) . METHOD_5 ( new org . apache . flink . IDENT_5 . pattern . IDENT_8 . IDENT_9 < org . apache . flink . IDENT_5 . METHOD_3 > ( ) { @ org . apache . flink . IDENT_5 . Override public boolean filter ( org . apache . flink . IDENT_5 . METHOD_3 value ) throws org . apache . flink . IDENT_5 . Exception { return value . getName ( ) . equals ( STRING_0 ) ; } } ) . METHOD_6 ( STRING_1 ) . METHOD_5 ( new org . apache . flink . IDENT_5 . pattern . IDENT_8 . IDENT_9 < org . apache . flink . IDENT_5 . METHOD_3 > ( ) { @ org . apache . flink . IDENT_5 . Override public boolean filter ( org . apache . flink . IDENT_5 . METHOD_3 value ) throws org . apache . flink . IDENT_5 . Exception { return ( value . METHOD_7 ( ) ) == 2.0 ; } } ) . METHOD_8 ( new org . apache . flink . IDENT_5 . pattern . IDENT_8 . IDENT_9 < org . apache . flink . IDENT_5 . METHOD_3 > ( ) { @ org . apache . flink . IDENT_5 . Override public boolean filter ( org . apache . flink . IDENT_5 . METHOD_3 value ) throws org . apache . flink . IDENT_5 . Exception { return ( value . METHOD_7 ( ) ) == FLOAT_2 ; } } ) . METHOD_6 ( STRING_2 ) . METHOD_5 ( new org . apache . flink . IDENT_5 . pattern . IDENT_8 . IDENT_9 < org . apache . flink . IDENT_5 . METHOD_3 > ( ) { @ org . apache . flink . IDENT_5 . Override public boolean filter ( org . apache . flink . IDENT_5 . METHOD_3 value ) throws org . apache . flink . IDENT_5 . Exception { return value . getName ( ) . equals ( STRING_2 ) ; } } ) ; org . apache . flink . streaming . api . IDENT_3 . IDENT_4 < java . lang . String > result = org . apache . flink . IDENT_5 . IDENT_10 . pattern ( input , pattern ) . select ( new org . apache . flink . IDENT_5 . IDENT_11 < org . apache . flink . IDENT_5 . METHOD_3 , java . lang . String > ( ) { @ org . apache . flink . IDENT_5 . Override public java . lang . String select ( java . util . Map < java . lang . String , java . util . List < org . apache . flink . IDENT_5 . METHOD_3 > > pattern ) { java . lang . StringBuilder builder = new java . lang . StringBuilder ( ) ; builder . append ( pattern . get ( STRING_0 ) . get ( 0 ) . getId ( ) ) . append ( STRING_3 ) . append ( pattern . get ( STRING_1 ) . get ( 0 ) . getId ( ) ) . append ( STRING_3 ) . append ( pattern . get ( STRING_2 ) . get ( 0 ) . getId ( ) ) ; return builder . toString ( ) ; } } ) ; java . util . List < java . lang . String > IDENT_12 = new java . util . ArrayList ( ) ; org . apache . flink . streaming . api . IDENT_3 . IDENT_13 . collect ( result ) . METHOD_9 ( IDENT_12 :: add ) ; java . util . List < java . lang . String > expected = java . util . Arrays . asList ( STRING_4 , STRING_5 , STRING_6 , STRING_7 ) ; expected . METHOD_10 ( String :: compareTo ) ; IDENT_12 . METHOD_10 ( String :: compareTo ) ; "<AssertPlaceHolder>" ; } METHOD_10 ( org . apache . flink . runtime . IDENT_14 . METHOD_10 . IDENT_15 ) { METHOD_10 ( s , 0 , s . size ( ) ) ; }
org . junit . Assert . assertEquals ( expected , IDENT_12 )