METHOD_0 ( ) { final org . apache . flink . api . common . IDENT_0 . IDENT_1 < org . apache . flink . types . IDENT_2 > IDENT_3 = org . apache . flink . IDENT_4 . json . IDENT_5 . convert ( ( STRING_0 2 + ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( STRING_0 3 + STRING_1 ) + STRING_0 ) + STRING_2 ) + STRING_0 6 ) + STRING_3 0 ) + STRING_3 3 ) + STRING_4 ) + STRING_3 6 ) + STRING_0 8 ) + STRING_3 2 ) + STRING_3 9 ) + STRING_0 7 ) + STRING_0 1 ) + STRING_5 ) + STRING_3 7 ) + STRING_0 0 ) + STRING_3 5 ) + STRING_0 4 ) + STRING_6 ) + STRING_0 5 ) ) ) ; final org . apache . flink . types . IDENT_2 row = new org . apache . flink . types . METHOD_1 ( INT_0 ) ; row . METHOD_2 ( 0 , java . math . BigDecimal . valueOf ( ( - INT_1 ) ) ) ; row . METHOD_2 ( 1 , java . math . BigDecimal . valueOf ( FLOAT_0 ) ) ; row . METHOD_2 ( 2 , null ) ; row . METHOD_2 ( 3 , STRING_3 1 ) ; row . METHOD_2 ( 4 , java . sql . Date . valueOf ( STRING_3 ) ) ; row . METHOD_2 ( 5 , java . sql . IDENT_6 . valueOf ( STRING_3 8 ) ) ; row . METHOD_2 ( 6 , java . sql . IDENT_7 . valueOf ( STRING_3 4 ) ) ; final byte [ ] bytes = new byte [ INT_2 ] ; java . util . concurrent . IDENT_8 . METHOD_3 ( ) . METHOD_4 ( bytes ) ; row . METHOD_2 ( 7 , bytes ) ; final java . math . BigDecimal [ ] IDENT_9 = new java . math . BigDecimal [ ] { java . math . BigDecimal . valueOf ( 1 ) , java . math . BigDecimal . valueOf ( 2 ) , java . math . BigDecimal . valueOf ( 3 ) } ; row . METHOD_2 ( 8 , IDENT_9 ) ; final java . lang . String [ ] IDENT_10 = new java . lang . String [ ] { STRING_7 , STRING_8 , STRING_9 } ; row . METHOD_2 ( 9 , IDENT_10 ) ; final org . apache . flink . types . METHOD_1 IDENT_11 = new org . apache . flink . types . METHOD_1 ( 2 ) ; IDENT_11 . METHOD_2 ( 0 , true ) ; IDENT_11 . METHOD_2 ( 1 , java . math . BigDecimal . valueOf ( 12 ) ) ; row . METHOD_2 ( 10 , IDENT_11 ) ; final org . apache . flink . types . METHOD_1 IDENT_12 = METHOD_5 ( IDENT_3 , row ) ; "<AssertPlaceHolder>" ; } METHOD_5 ( IDENT_13 extends org . apache . flink . streaming . runtime . IDENT_14 . IDENT_15 , org . apache . flink . streaming . runtime . IDENT_14 . IDENT_16 ) { org . apache . flink . core . IDENT_17 . IDENT_18 output = new org . apache . flink . core . IDENT_17 . METHOD_6 ( INT_3 ) ; serializer . serialize ( record , output ) ; org . apache . flink . core . IDENT_17 . IDENT_19 IDENT_20 = new org . apache . flink . core . IDENT_17 . METHOD_7 ( output . METHOD_8 ( ) , 0 , output . length ( ) ) ; org . apache . flink . core . IDENT_17 . METHOD_6 IDENT_21 = new org . apache . flink . core . IDENT_17 . METHOD_6 ( INT_3 ) ; serializer . METHOD_9 ( IDENT_20 , IDENT_21 ) ; org . apache . flink . core . IDENT_17 . METHOD_7 input = new org . apache . flink . core . IDENT_17 . METHOD_7 ( IDENT_21 . METHOD_8 ( ) , 0 , IDENT_21 . length ( ) ) ; return ( ( IDENT_13 ) ( serializer . METHOD_10 ( input ) ) ) ; }
org . junit . Assert . assertEquals ( row , IDENT_12 )