METHOD_0 ( ) { org . apache . beam . sdk . io . IDENT_0 . IDENT_1 < java . lang . Long > transform = org . apache . beam . sdk . io . IDENT_0 . from ( org . apache . beam . sdk . io . IDENT_2 . METHOD_1 ( ) ) ; final org . apache . beam . sdk . values . IDENT_3 < java . lang . Long > output = pipeline . apply ( transform ) ; final org . apache . beam . sdk . IDENT_4 . IDENT_5 . IDENT_6 < java . lang . Long > consumer = org . apache . beam . sdk . IDENT_4 . IDENT_5 . METHOD_2 ( ) ; org . apache . beam . sdk . values . IDENT_7 . of ( output ) . apply ( consumer ) ; org . apache . beam . runners . core . IDENT_8 . IDENT_9 . METHOD_3 ( pipeline ) ; pipeline . METHOD_4 ( new org . apache . beam . sdk . IDENT_10 . IDENT_11 . METHOD_5 ( ) { @ org . apache . beam . runners . core . IDENT_8 . Override public void METHOD_6 ( org . apache . beam . sdk . runners . IDENT_12 . Node node ) { if ( node . METHOD_7 ( ) . values ( ) . contains ( output ) ) { "<AssertPlaceHolder>" ; } } } ) ; } METHOD_8 ( ) { return transform ; }
org . junit . Assert . assertThat ( node . METHOD_8 ( ) , org . hamcrest . Matchers . is ( consumer ) )