METHOD_0 ( ) { java . util . List < org . apache . avro . Schema . Field > fields = new java . util . ArrayList ( ) ; java . util . Map < java . lang . String , java . lang . Object > data = new java . util . HashMap ( ) ; for ( int i = 0 ; i < ( com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_5 . length ) ; ++ i ) { org . apache . avro . Schema . Field field = new org . apache . avro . Schema . Field ( com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_6 [ i ] , org . apache . avro . Schema . create ( com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_7 [ i ] ) , null , null ) ; fields . add ( field ) ; data . put ( com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_6 [ i ] , com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_5 [ i ] ) ; } fields . add ( new org . apache . avro . Schema . Field ( STRING_0 , org . apache . avro . Schema . METHOD_1 ( STRING_1 , null , null , 10 ) , null , null ) ) ; data . put ( STRING_0 , STRING_2 . getBytes ( ) ) ; fields . add ( new org . apache . avro . Schema . Field ( STRING_3 , org . apache . avro . Schema . METHOD_2 ( org . apache . avro . Schema . create ( Schema . Type . IDENT_8 ) ) , null , null ) ) ; java . util . List < java . lang . Integer > IDENT_9 = new java . util . ArrayList ( ) ; IDENT_9 . add ( 1 ) ; IDENT_9 . add ( 2 ) ; data . put ( STRING_3 , IDENT_9 ) ; org . apache . avro . Schema schema = org . apache . avro . Schema . METHOD_3 ( fields ) ; org . apache . avro . IDENT_10 . IDENT_11 expected = new org . apache . avro . IDENT_10 . IDENT_12 . METHOD_4 ( schema ) ; for ( int i = 0 ; i < ( com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_5 . length ) ; ++ i ) { expected . put ( com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_6 [ i ] , com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_5 [ i ] ) ; } expected . put ( STRING_0 , new org . apache . avro . IDENT_10 . IDENT_12 . METHOD_5 ( org . apache . avro . Schema . METHOD_1 ( STRING_1 , null , null , 10 ) , STRING_2 . getBytes ( ) ) ) ; expected . put ( STRING_3 , new org . apache . avro . IDENT_10 . IDENT_12 . IDENT_13 < java . lang . Integer > ( org . apache . avro . Schema . METHOD_2 ( org . apache . avro . Schema . create ( Schema . Type . IDENT_8 ) ) , IDENT_9 ) ) ; com . IDENT_0 . IDENT_1 . streams . IDENT_14 IDENT_15 = com . IDENT_0 . IDENT_1 . streams . common . IDENT_16 . builder ( ) . METHOD_6 ( data ) . METHOD_7 ( STRING_4 ) . build ( ) ; "<AssertPlaceHolder>" ; } METHOD_8 ( com . IDENT_0 . IDENT_1 . streams . IDENT_14 , org . apache . avro . Schema ) { if ( IDENT_15 . containsKey ( IDENT_14 . IDENT_17 ) ) { if ( ( IDENT_15 . METHOD_9 ( ) . size ( ) ) > 1 ) { throw new java . lang . RuntimeException ( STRING_5 ) ; } return IDENT_15 . get ( IDENT_14 . IDENT_17 ) ; } org . apache . avro . IDENT_10 . IDENT_11 result ; result = new org . apache . avro . IDENT_10 . IDENT_12 . METHOD_4 ( schema ) ; for ( Map . Entry < java . lang . String , java . lang . Object > entry : IDENT_15 . entrySet ( ) ) { result . put ( entry . getKey ( ) , com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_18 . METHOD_10 ( entry . getValue ( ) , schema . METHOD_11 ( entry . getKey ( ) ) . schema ( ) ) ) ; } return result ; }
org . junit . Assert . assertEquals ( expected , com . IDENT_0 . IDENT_1 . streams . runtime . IDENT_2 . IDENT_3 . kafka . IDENT_18 . METHOD_8 ( IDENT_15 , schema ) )