METHOD_0 ( ) { org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . IDENT_2 < org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . IDENT_3 . IDENT_4 > IDENT_5 = new org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . METHOD_1 ( org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . IDENT_3 . IDENT_4 . class , new org . apache . flink . api . common . METHOD_2 ( ) ) ; org . apache . flink . api . common . IDENT_0 . IDENT_6 IDENT_7 = IDENT_5 . METHOD_3 ( ) ; byte [ ] IDENT_8 ; try ( java . io . ByteArrayOutputStream out = new java . io . ByteArrayOutputStream ( ) ) { org . apache . flink . api . common . IDENT_0 . IDENT_9 . METHOD_4 ( new org . apache . flink . core . IDENT_10 . METHOD_5 ( out ) , IDENT_7 , IDENT_5 ) ; IDENT_8 = out . toByteArray ( ) ; } org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . METHOD_1 < org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . IDENT_3 . IDENT_11 > IDENT_12 = new org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . METHOD_1 ( org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . IDENT_3 . IDENT_11 . class , new org . apache . flink . api . common . METHOD_2 ( ) ) ; try ( java . io . ByteArrayInputStream in = new java . io . ByteArrayInputStream ( IDENT_8 ) ) { IDENT_7 = org . apache . flink . api . common . IDENT_0 . IDENT_9 . METHOD_6 ( new org . apache . flink . core . IDENT_10 . METHOD_7 ( in ) , java . lang . Thread . METHOD_8 ( ) . METHOD_9 ( ) , IDENT_12 ) ; } @ org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . METHOD_10 ( STRING_0 ) org . apache . flink . api . common . IDENT_0 . IDENT_13 < org . apache . flink . api . java . IDENT_0 . runtime . IDENT_1 . IDENT_3 . IDENT_11 > IDENT_14 = IDENT_7 . METHOD_11 ( IDENT_12 ) ; "<AssertPlaceHolder>" ; } METHOD_12 ( ) { return ( IDENT_15 ) == ( IDENT_13 . Type . IDENT_16 ) ; }
org . junit . Assert . assertTrue ( IDENT_14 . METHOD_12 ( ) )