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 . api . java . tuple . IDENT_5 < java . lang . Integer , java . lang . String > > input = IDENT_2 . METHOD_2 ( new org . apache . flink . api . java . tuple . METHOD_3 ( 1 , "a" ) , new org . apache . flink . api . java . tuple . METHOD_3 ( 2 , "a" ) , new org . apache . flink . api . java . tuple . METHOD_3 ( 3 , "a" ) , new org . apache . flink . api . java . tuple . METHOD_3 ( 4 , "a" ) ) ; org . apache . flink . IDENT_6 . pattern . IDENT_7 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > , ? > pattern = org . apache . flink . IDENT_6 . pattern . IDENT_7 . < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > > METHOD_4 ( STRING_0 , org . apache . flink . IDENT_6 . IDENT_8 . IDENT_9 . IDENT_10 . METHOD_5 ( ) ) . METHOD_6 ( new org . apache . flink . IDENT_6 . pattern . IDENT_11 . IDENT_12 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > > ( ) { @ org . apache . flink . IDENT_6 . Override public boolean filter ( org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > IDENT_13 ) throws org . apache . flink . IDENT_6 . Exception { return IDENT_13 . IDENT_14 . equals ( "a" ) ; } } ) . times ( 2 ) ; org . apache . flink . IDENT_6 . IDENT_15 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > > IDENT_16 = org . apache . flink . IDENT_6 . IDENT_17 . pattern ( input , pattern ) ; org . apache . flink . streaming . api . IDENT_3 . IDENT_4 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > > result = IDENT_16 . select ( new org . apache . flink . IDENT_6 . IDENT_18 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > , org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > > ( ) { @ org . apache . flink . IDENT_6 . Override public org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > select ( java . util . Map < java . lang . String , java . util . List < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > > > pattern ) throws org . apache . flink . IDENT_6 . Exception { return pattern . get ( STRING_0 ) . get ( 0 ) ; } } ) ; java . util . List < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > > IDENT_19 = new java . util . ArrayList ( ) ; org . apache . flink . streaming . api . IDENT_3 . IDENT_20 . collect ( result ) . METHOD_7 ( IDENT_19 :: add ) ; IDENT_19 . METHOD_8 ( java . util . IDENT_21 . METHOD_9 ( ( IDENT_22 ) -> IDENT_22 . toString ( ) ) ) ; java . util . List < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . String > > expected = java . util . Arrays . asList ( org . apache . flink . api . java . tuple . METHOD_3 . of ( 1 , "a" ) , org . apache . flink . api . java . tuple . METHOD_3 . of ( 3 , "a" ) ) ; "<AssertPlaceHolder>" ; } of ( IDENT_23 , IDENT_24 ) { return new org . apache . flink . api . java . tuple . METHOD_3 < > ( IDENT_25 , IDENT_26 ) ; }
org . junit . Assert . assertEquals ( expected , IDENT_19 )