org.apache.avro.hadoop.io

Class AvroKeyDeserializer<D>

java.lang.Object

org.apache.avro.hadoop.io.AvroDeserializer<AvroWrapper<D>,D>

org.apache.avro.hadoop.io.AvroKeyDeserializer<D>

Type Parameters:

D - The java type of the avro data to deserialize.

All Implemented Interfaces:

org.apache.hadoop.io.serializer.Deserializer<AvroWrapper<D>>

public class AvroKeyDeserializer<D>
extends AvroDeserializer<AvroWrapper<D>,D>

Deserializes AvroKey objects within Hadoop.

See Also:

AvroDeserializer

Constructor Summary

Constructors

Constructor and Description
AvroKeyDeserializer(Schema writerSchema, Schema readerSchema, ClassLoader classLoader) Constructor.
AvroKeyDeserializer(Schema writerSchema, Schema readerSchema, DatumReader<D> datumReader) Constructor.

Method Summary

Modifier and Type	Method and Description
protected AvroWrapper<D>	createAvroWrapper() Creates a new empty AvroKey instance.

Methods inherited from class org.apache.avro.hadoop.io.AvroDeserializer

close, deserialize, getReaderSchema, getWriterSchema, open

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroKeyDeserializer

public AvroKeyDeserializer(Schema writerSchema,
                           Schema readerSchema,
                           ClassLoader classLoader)

Constructor.

Parameters:

writerSchema - The Avro writer schema for the data to deserialize.

readerSchema - The Avro reader schema for the data to deserialize.

AvroKeyDeserializer

public AvroKeyDeserializer(Schema writerSchema,
                           Schema readerSchema,
                           DatumReader<D> datumReader)

Constructor.

Parameters:

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.

Method Detail

createAvroWrapper

protected AvroWrapper<D> createAvroWrapper()

Creates a new empty AvroKey instance.

Specified by:

createAvroWrapper in class AvroDeserializer<AvroWrapper<D>,D>

Returns:

a new empty AvroKey.