METHOD_0 ( ) { try { final java . lang . String IDENT_0 = STRING_0 ; final org . apache . flink . core . fs . IDENT_1 split = org . apache . flink . api . common . io . IDENT_2 . METHOD_1 ( IDENT_0 ) ; final org . apache . flink . configuration . Configuration parameters = new org . apache . flink . configuration . Configuration ( ) ; format . METHOD_2 ( STRING_1 ) ; format . METHOD_3 ( org . apache . flink . types . IDENT_3 . class , org . apache . flink . types . IDENT_4 . class , org . apache . flink . types . IDENT_3 . class , org . apache . flink . types . IDENT_4 . class ) ; format . METHOD_4 ( parameters ) ; format . METHOD_5 ( split ) ; org . apache . flink . types . IDENT_5 [ ] values = new org . apache . flink . types . IDENT_5 [ ] { new org . apache . flink . types . METHOD_6 ( ) , new org . apache . flink . types . METHOD_7 ( ) , new org . apache . flink . types . METHOD_6 ( ) , new org . apache . flink . types . METHOD_7 ( ) } ; "<AssertPlaceHolder>" ; try { format . METHOD_8 ( values ) ; org . junit . Assert . fail ( STRING_2 ) ; } catch ( org . apache . flink . api . common . io . IDENT_6 IDENT_7 ) { } } catch ( java . lang . Exception ex ) { org . junit . Assert . fail ( ( ( ( STRING_3 + ( ex . getClass ( ) . METHOD_9 ( ) ) ) + STRING_4 ) + ( ex . getMessage ( ) ) ) ) ; } } METHOD_8 ( IDENT_8 ) { if ( METHOD_10 ( ) ) { return null ; } if ( ( IDENT_9 . METHOD_11 ( ) ) != ( IDENT_10 ) ) { IDENT_10 = IDENT_9 . METHOD_11 ( ) ; IDENT_11 = 0 ; } ( IDENT_11 ) ++ ; if ( IDENT_12 ) { return IDENT_9 . next ( IDENT_13 ) ; } else { if ( ( org . apache . avro . IDENT_14 . IDENT_15 . class ) == ( IDENT_16 ) ) { return IDENT_9 . next ( ) ; } else { return IDENT_9 . next ( org . apache . flink . util . IDENT_17 . METHOD_12 ( IDENT_16 , java . lang . Object . class ) ) ; } } }
org . junit . Assert . assertNotNull ( format . METHOD_8 ( values ) )