test ( ) { java . io . IDENT_0 out = new java . io . METHOD_0 ( IDENT_1 ) ; java . lang . String IDENT_2 = IDENT_3 . Builder . class . getName ( ) ; org . apache . IDENT_4 . Context ctx = new org . apache . IDENT_4 . Context ( ) ; ctx . put ( STRING_0 , STRING_1 1 ) ; ctx . put ( STRING_2 , STRING_3 ) ; org . apache . IDENT_4 . serialization . IDENT_5 serializer = org . apache . IDENT_4 . serialization . IDENT_6 . getInstance ( IDENT_2 , ctx , out ) ; serializer . METHOD_1 ( ) ; java . util . List < org . apache . IDENT_4 . IDENT_7 > events = nl . info . IDENT_4 . serialization . IDENT_8 . METHOD_2 ( ) ; for ( org . apache . IDENT_4 . IDENT_7 e : events ) { serializer . write ( e ) ; } serializer . METHOD_3 ( ) ; serializer . METHOD_4 ( ) ; out . METHOD_3 ( ) ; out . close ( ) ; org . apache . avro . io . IDENT_9 < org . apache . avro . IDENT_10 . IDENT_11 > reader = new org . apache . avro . IDENT_10 . IDENT_12 < org . apache . avro . IDENT_10 . IDENT_11 > ( ) ; org . apache . avro . file . IDENT_13 < org . apache . avro . IDENT_10 . IDENT_11 > IDENT_14 = new org . apache . avro . file . IDENT_13 < org . apache . avro . IDENT_10 . IDENT_11 > ( IDENT_1 , reader ) ; org . apache . avro . IDENT_10 . IDENT_11 record = new org . apache . avro . IDENT_10 . IDENT_15 . METHOD_5 ( IDENT_14 . METHOD_6 ( ) ) ; int IDENT_16 = 0 ; while ( IDENT_14 . hasNext ( ) ) { IDENT_14 . next ( record ) ; long IDENT_17 = ( ( java . lang . Long ) ( record . get ( STRING_4 ) ) ) ; java . lang . String IDENT_18 = record . get ( STRING_5 ) . toString ( ) ; java . lang . String IDENT_19 = record . get ( STRING_6 ) . toString ( ) ; java . util . Map < java . lang . String , java . lang . String > headers = ( ( java . util . Map < java . lang . String , java . lang . String > ) ( record . get ( STRING_1 2 ) ) ) ; java . lang . String message = record . get ( STRING_7 ) . toString ( ) ; System . out . println ( ( ( ( ( ( IDENT_19 + STRING_1 ) + headers ) + STRING_8 ) + STRING_9 ) + message ) ) ; IDENT_16 ++ ; } IDENT_14 . close ( ) ; "<AssertPlaceHolder>" ; org . apache . commons . io . IDENT_20 . METHOD_7 ( IDENT_1 ) ; } close ( ) { }
org . junit . Assert . assertEquals ( STRING_1 0 , 6 , IDENT_16 )