METHOD_0 ( ) { org . apache . flink . api . java . IDENT_0 < org . apache . flink . graph . IDENT_1 < org . apache . flink . types . IDENT_2 , org . apache . flink . types . IDENT_2 > > IDENT_3 ; IDENT_3 = IDENT_4 . run ( new org . apache . flink . graph . IDENT_5 . IDENT_3 . IDENT_6 . IDENT_7 . IDENT_8 < org . apache . flink . types . IDENT_2 , org . apache . flink . types . IDENT_9 , org . apache . flink . types . IDENT_9 > ( ) . METHOD_1 ( false ) ) ; "<AssertPlaceHolder>" ; IDENT_3 = IDENT_4 . run ( new org . apache . flink . graph . IDENT_5 . IDENT_3 . IDENT_6 . IDENT_7 . IDENT_8 < org . apache . flink . types . IDENT_2 , org . apache . flink . types . IDENT_9 , org . apache . flink . types . IDENT_9 > ( ) . METHOD_1 ( true ) ) ; java . lang . String IDENT_10 = STRING_0 + ( STRING_1 + STRING_2 ) ; org . apache . flink . test . util . IDENT_11 . METHOD_2 ( IDENT_3 . collect ( ) , IDENT_10 ) ; } collect ( ) { final java . lang . String id = new org . apache . flink . util . METHOD_3 ( ) . toString ( ) ; final org . apache . flink . api . common . IDENT_12 . IDENT_13 < T > serializer = getType ( ) . METHOD_4 ( METHOD_5 ( ) . METHOD_6 ( ) ) ; this . output ( new org . apache . flink . api . java . Utils . IDENT_14 < > ( id , serializer ) ) . name ( STRING_3 ) ; org . apache . flink . api . common . IDENT_15 res = METHOD_5 ( ) . execute ( ) ; java . util . ArrayList < byte [ ] > IDENT_16 = res . METHOD_7 ( id ) ; if ( IDENT_16 != null ) { try { return org . apache . flink . api . common . IDENT_17 . IDENT_18 . METHOD_8 ( IDENT_16 , serializer ) ; } catch ( java . lang . IDENT_19 e ) { throw new java . lang . RuntimeException ( STRING_4 , e ) ; } catch ( java . io . IOException e ) { throw new java . lang . RuntimeException ( STRING_5 , e ) ; } } else { throw new java . lang . RuntimeException ( STRING_6 ) ; } }
org . junit . Assert . assertEquals ( 0 , IDENT_3 . collect ( ) . size ( ) )