public static < T > T readAvroEntity ( Decoder decoder , DatumReader < T > reader ) { try { return reader . read ( null , decoder ) ; } catch ( IOException e ) { throw new SerializationException ( "Could not deserialize Avro entity" , e ) ; } }
Decode an entity from the initialized Avro Decoder using the DatumReader .