METHOD_0 ( ) { org . apache . flink . types . IDENT_0 row = org . apache . flink . types . IDENT_0 . of ( 1 , "test" , FLOAT_0 , org . apache . flink . streaming . IDENT_1 . schema . IDENT_2 . IDENT_3 ) ; org . apache . flink . streaming . IDENT_1 . schema . IDENT_4 < org . apache . flink . types . IDENT_0 > schema = new org . apache . flink . streaming . IDENT_1 . schema . METHOD_1 ( new org . apache . flink . api . java . IDENT_5 . METHOD_2 ( org . apache . flink . api . java . IDENT_5 . IDENT_6 . METHOD_3 ( org . apache . flink . streaming . IDENT_1 . schema . Integer . class ) , org . apache . flink . api . java . IDENT_5 . IDENT_6 . METHOD_3 ( java . lang . String . class ) , org . apache . flink . api . java . IDENT_5 . IDENT_6 . METHOD_3 ( org . apache . flink . streaming . IDENT_1 . schema . Double . class ) , org . apache . flink . api . java . IDENT_5 . IDENT_6 . METHOD_3 ( org . apache . flink . streaming . IDENT_1 . schema . Long . class ) ) , STRING_0 , "name" , STRING_1 , STRING_2 ) ; org . apache . flink . streaming . IDENT_1 . schema . IDENT_7 < org . apache . flink . types . IDENT_0 > reader = new org . apache . flink . streaming . IDENT_1 . schema . METHOD_4 ( schema ) ; "<AssertPlaceHolder>" ; } METHOD_5 ( T ) { org . apache . flink . util . IDENT_8 . METHOD_6 ( ( ( input . getClass ( ) ) == ( schema . METHOD_7 ( ) . METHOD_8 ( ) ) ) , ( ( ( STRING_3 + input ) + STRING_4 ) + ( schema . METHOD_7 ( ) ) ) ) ; java . lang . Object [ ] data ; if ( schema . METHOD_9 ( ) ) { data = new java . lang . Object [ ] { input } ; } else if ( schema . METHOD_10 ( ) ) { org . apache . flink . api . java . tuple . IDENT_9 tuple = ( ( org . apache . flink . api . java . tuple . IDENT_9 ) ( input ) ) ; data = new java . lang . Object [ schema . METHOD_11 ( ) . length ] ; for ( int i = 0 ; i < ( schema . METHOD_11 ( ) . length ) ; i ++ ) { data [ i ] = tuple . METHOD_12 ( schema . METHOD_11 ( ) [ i ] ) ; } } else if ( schema . METHOD_13 ( ) ) { org . apache . flink . types . IDENT_0 row = ( ( org . apache . flink . types . IDENT_0 ) ( input ) ) ; data = new java . lang . Object [ schema . METHOD_11 ( ) . length ] ; for ( int i = 0 ; i < ( schema . METHOD_11 ( ) . length ) ; i ++ ) { data [ i ] = row . METHOD_12 ( schema . METHOD_11 ( ) [ i ] ) ; } } else if ( ( schema . METHOD_14 ( ) ) || ( schema . METHOD_15 ( ) ) ) { data = new java . lang . Object [ schema . METHOD_11 ( ) . length ] ; for ( int i = 0 ; i < ( schema . METHOD_16 ( ) . length ) ; i ++ ) { data [ i ] = METHOD_17 ( schema . METHOD_16 ( ) [ i ] , input ) ; } } else { throw new java . lang . IllegalArgumentException ( ( STRING_5 + ( schema . METHOD_7 ( ) ) ) ) ; } return data ; }
org . junit . Assert . assertArrayEquals ( new java . lang . Object [ ] { 1 , "test" , FLOAT_0 , org . apache . flink . streaming . IDENT_1 . schema . IDENT_2 . IDENT_3 } , reader . METHOD_5 ( row ) )