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 . Integer > > input = IDENT_2 . METHOD_2 ( new org . apache . flink . api . java . tuple . METHOD_3 ( 0 , 1 ) , new org . apache . flink . api . java . tuple . METHOD_3 ( 0 , 2 ) ) ; org . apache . flink . IDENT_6 . pattern . IDENT_7 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > , ? > pattern = org . apache . flink . IDENT_6 . pattern . IDENT_7 . < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > > METHOD_4 ( STRING_0 ) . METHOD_5 ( new org . apache . flink . IDENT_6 . pattern . IDENT_8 . IDENT_9 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > > ( ) { @ org . apache . flink . IDENT_6 . Override public boolean filter ( org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > IDENT_10 ) throws org . apache . flink . IDENT_6 . Exception { return ( IDENT_10 . IDENT_11 ) == 1 ; } } ) ; org . apache . flink . IDENT_6 . IDENT_12 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > > IDENT_13 = org . apache . flink . IDENT_6 . IDENT_14 . 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 . Integer > > result = IDENT_13 . select ( new org . apache . flink . IDENT_6 . IDENT_15 < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > , org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > > ( ) { @ org . apache . flink . IDENT_6 . Override public org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > select ( java . util . Map < java . lang . String , java . util . List < org . apache . flink . api . java . tuple . METHOD_3 < java . lang . Integer , java . lang . Integer > > > 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 . Integer > > IDENT_16 = new java . util . ArrayList ( ) ; org . apache . flink . streaming . api . IDENT_3 . IDENT_17 . collect ( result ) . METHOD_6 ( IDENT_16 :: add ) ; "<AssertPlaceHolder>" ; } METHOD_6 ( java . util . function . IDENT_18 ) { delegate . METHOD_6 ( action ) ; }
org . junit . Assert . assertEquals ( java . util . Arrays . asList ( new org . apache . flink . api . java . tuple . METHOD_3 ( 0 , 1 ) ) , IDENT_16 )