METHOD_0 ( ) { final org . apache . flink . api . common . IDENT_0 . IDENT_1 < T > serializer = METHOD_1 ( ) ; final org . apache . flink . api . common . IDENT_0 . IDENT_2 < T > IDENT_3 = serializer . METHOD_2 ( ) ; byte [ ] IDENT_4 ; try ( java . io . ByteArrayOutputStream out = new java . io . ByteArrayOutputStream ( ) ) { org . apache . flink . api . common . IDENT_0 . IDENT_5 . METHOD_3 ( new org . apache . flink . core . IDENT_6 . METHOD_4 ( out ) , IDENT_3 , serializer ) ; IDENT_4 = out . toByteArray ( ) ; } org . apache . flink . api . common . IDENT_0 . IDENT_2 < T > IDENT_7 ; try ( java . io . ByteArrayInputStream in = new java . io . ByteArrayInputStream ( IDENT_4 ) ) { IDENT_7 = org . apache . flink . api . common . IDENT_0 . IDENT_5 . METHOD_5 ( new org . apache . flink . core . IDENT_6 . METHOD_6 ( in ) , java . lang . Thread . METHOD_7 ( ) . METHOD_8 ( ) , METHOD_1 ( ) ) ; } org . apache . flink . api . common . IDENT_0 . IDENT_8 < T > strategy = IDENT_7 . METHOD_9 ( METHOD_1 ( ) ) ; final org . apache . flink . api . common . IDENT_0 . IDENT_1 < T > IDENT_9 ; if ( strategy . METHOD_10 ( ) ) { IDENT_9 = IDENT_7 . METHOD_11 ( ) ; } else if ( strategy . METHOD_12 ( ) ) { METHOD_11 = strategy . METHOD_13 ( ) ; } else { throw new java . lang . METHOD_14 ( ( STRING_0 + strategy ) ) ; } "<AssertPlaceHolder>" ; } METHOD_13 ( ) { org . apache . flink . util . IDENT_10 . METHOD_15 ( METHOD_12 ( ) , STRING_1 , org . apache . flink . api . common . IDENT_0 . IDENT_8 . Type . IDENT_11 , IDENT_12 ) ; return IDENT_13 ; }
org . junit . Assert . assertEquals ( serializer . getClass ( ) , METHOD_11 . getClass ( ) )