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 ) ; java . util . List < com . baeldung . flink . model . METHOD_1 > messages = java . util . Arrays . asList ( message ) ; com . baeldung . flink . model . IDENT_2 IDENT_3 = new com . baeldung . flink . model . METHOD_2 ( messages , java . time . IDENT_1 . now ( ) ) ; byte [ ] IDENT_4 = com . baeldung . flink . IDENT_5 . mapper . METHOD_3 ( IDENT_3 ) ; org . apache . flink . api . common . serialization . IDENT_6 < com . baeldung . flink . model . METHOD_2 > IDENT_7 = new com . baeldung . flink . schema . METHOD_4 ( ) ; byte [ ] IDENT_8 = IDENT_7 . serialize ( IDENT_3 ) ; "<AssertPlaceHolder>" ; } serialize ( com . baeldung . flink . model . METHOD_2 ) { if ( ( com . baeldung . flink . schema . METHOD_4 . IDENT_9 ) == null ) { com . baeldung . flink . schema . METHOD_4 . IDENT_9 . METHOD_5 ( com . fasterxml . jackson . annotation . IDENT_10 . IDENT_11 , com . fasterxml . jackson . annotation . IDENT_12 . IDENT_13 . IDENT_14 ) ; com . baeldung . flink . schema . METHOD_4 . IDENT_9 = new com . fasterxml . jackson . databind . METHOD_6 ( ) . METHOD_7 ( new com . fasterxml . jackson . IDENT_15 . IDENT_16 . METHOD_8 ( ) ) ; } try { java . lang . String json = com . baeldung . flink . schema . METHOD_4 . IDENT_9 . METHOD_9 ( IDENT_17 ) ; return json . getBytes ( ) ; } catch ( com . fasterxml . jackson . core . IDENT_18 e ) { logger . error ( STRING_3 , e ) ; } return new byte [ 0 ] ; }
org . junit . Assert . assertEquals ( IDENT_4 , IDENT_8 )