D
- The java type of the avro data to deserialize.public class AvroKeyDeserializer<D> extends AvroDeserializer<AvroWrapper<D>,D>
AvroDeserializer
Constructor and Description |
---|
AvroKeyDeserializer(Schema writerSchema,
Schema readerSchema,
ClassLoader classLoader)
Constructor.
|
AvroKeyDeserializer(Schema writerSchema,
Schema readerSchema,
DatumReader<D> datumReader)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected AvroWrapper<D> |
createAvroWrapper()
Creates a new empty
AvroKey instance. |
close, deserialize, getReaderSchema, getWriterSchema, open
public AvroKeyDeserializer(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 AvroKeyDeserializer(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()
AvroKey
instance.createAvroWrapper
in class AvroDeserializer<AvroWrapper<D>,D>
Copyright © 2009–2020 The Apache Software Foundation. All rights reserved.