D
- The java type of the avro data to deserialize.public class AvroValueDeserializer<D> extends AvroDeserializer<AvroWrapper<D>,D>
AvroDeserializer
Constructor and Description |
---|
AvroValueDeserializer(Schema writerSchema,
Schema readerSchema,
ClassLoader classLoader)
Constructor.
|
AvroValueDeserializer(Schema writerSchema,
Schema readerSchema,
DatumReader<D> datumReader)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected AvroWrapper<D> |
createAvroWrapper()
Creates a new empty
AvroValue instance. |
close, deserialize, getReaderSchema, getWriterSchema, open
public AvroValueDeserializer(Schema writerSchema, Schema readerSchema, ClassLoader classLoader)
writerSchema
- The Avro writer schema for the data to deserialize.readerSchema
- The Avro reader schema for the data to deserialize.public AvroValueDeserializer(Schema writerSchema, Schema readerSchema, DatumReader<D> datumReader)
writerSchema
- The Avro writer schema for the data to deserialize.readerSchema
- The Avro reader schema for the data to deserialize.datumReader
- The Avro datum reader to use for deserialization.protected AvroWrapper<D> createAvroWrapper()
AvroValue
instance.createAvroWrapper
in class AvroDeserializer<AvroWrapper<D>,D>
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.