METHOD_0 ( ) { java . lang . String payload = "test" ; org . apache . flink . core . io . IDENT_0 . IDENT_1 IDENT_2 = new org . apache . flink . core . io . IDENT_0 . METHOD_1 ( 1 , payload ) ; byte [ ] IDENT_3 ; try ( org . apache . flink . core . IDENT_4 . IDENT_5 out = new org . apache . flink . core . IDENT_4 . METHOD_2 ( ) ) { IDENT_2 . write ( new org . apache . flink . core . IDENT_4 . METHOD_3 ( out ) ) ; IDENT_3 = out . toByteArray ( ) ; } IDENT_2 = new org . apache . flink . core . io . IDENT_0 . METHOD_1 ( 1 ) ; try ( org . apache . flink . core . IDENT_4 . IDENT_6 in = new org . apache . flink . core . IDENT_4 . METHOD_4 ( IDENT_3 ) ) { IDENT_2 . read ( new org . apache . flink . core . IDENT_4 . METHOD_5 ( in ) ) ; } "<AssertPlaceHolder>" ; } METHOD_6 ( ) { return data ; }
org . junit . Assert . assertEquals ( payload , IDENT_2 . METHOD_6 ( ) )