METHOD_0 ( ) { com . baeldung . flink . model . IDENT_0 message = new com . baeldung . flink . model . METHOD_1 ( STRING_0 , STRING_1 , java . time . IDENT_1 . now ( ) , STRING_2 ) ; byte [ ] IDENT_2 = com . baeldung . flink . IDENT_3 . mapper . METHOD_2 ( message ) ; org . apache . flink . api . common . serialization . IDENT_4 < com . baeldung . flink . model . METHOD_1 > IDENT_5 = new com . baeldung . flink . schema . METHOD_3 ( ) ; com . baeldung . flink . model . METHOD_1 IDENT_6 = IDENT_5 . METHOD_4 ( IDENT_2 ) ; "<AssertPlaceHolder>" ; } METHOD_4 ( byte [ ] ) { return com . baeldung . flink . schema . METHOD_3 . IDENT_7 . METHOD_5 ( bytes , com . baeldung . flink . model . METHOD_1 . class ) ; }
org . junit . Assert . assertEquals ( message , IDENT_6 )