Top Description Constructors Methods
org.apache.avro.specific

public Class SpecificDatumReader<T>

extends GenericDatumReader<T>
Class Inheritance
Known Direct Subclasses
org.apache.avro.reflect.ReflectDatumReader
Imports
org.apache.avro.Conversion, .Schema, .AvroRuntimeException, org.apache.avro.generic.GenericDatumReader, org.apache.avro.io.ResolvingDecoder, org.apache.avro.util.ClassUtils, java.io.IOException
DatumReader for generated Java classes.

Constructor Summary

AccessConstructor and Description
public
SpecificDatumReader()

public
SpecificDatumReader(Class<T> c)

Construct for reading instances of a class.

public
SpecificDatumReader(Schema schema)

Construct where the writer's and reader's schemas are the same.

public
SpecificDatumReader(Schema writer, Schema reader)

Construct given writer's and reader's schema.

public
SpecificDatumReader(Schema writer, Schema reader, SpecificData data)

Construct given writer's schema, reader's schema, and a SpecificData.

public
SpecificDatumReader(SpecificData data)

Construct given a SpecificData.

Method Summary

Modifier and TypeMethod and Description
protected Class<T>
findStringClass(Schema schema)

Overrides org.apache.avro.generic.GenericDatumReader.findStringClass.

Determines the class to used to represent a string Schema.
private Class<T>
getPropAsClass(Schema schema, String prop)

public SpecificData
getSpecificData()

Return the contained SpecificData.

protected void
readField(Object record, Schema.Field field, Object oldDatum, ResolvingDecoder in, Object state)

Overrides org.apache.avro.generic.GenericDatumReader.readField.

Called to read a single field of a record.
protected Object
readRecord(Object old, Schema expected, ResolvingDecoder in)

Overrides org.apache.avro.generic.GenericDatumReader.readRecord.

Called to read a record instance.
public void
setSchema(Schema actual)

Overrides org.apache.avro.generic.GenericDatumReader.setSchema.

Implements org.apache.avro.io.DatumReader.setSchema.

Set the writer's schema.
Inherited from org.apache.avro.generic.GenericDatumReader:
addToArrayaddToMapconvertcreateBytescreateEnumcreateFixedcreateFixedcreateStringgetDatagetExpectedgetResolvergetSchemanewArraynewInstanceFromStringnewMapnewRecordpeekArrayreadreadreadArrayreadBytesreadBytesreadEnumreadFixedreadIntreadMapreadMapKeyreadStringreadStringreadWithConversionreadWithoutConversionsetExpectedskip

Constructor Detail

SpecificDatumReaderback to summary
public SpecificDatumReader()
SpecificDatumReaderback to summary
public SpecificDatumReader(Class<T> c)

Construct for reading instances of a class.

SpecificDatumReaderback to summary
public SpecificDatumReader(Schema schema)

Construct where the writer's and reader's schemas are the same.

SpecificDatumReaderback to summary
public SpecificDatumReader(Schema writer, Schema reader)

Construct given writer's and reader's schema.

SpecificDatumReaderback to summary
public SpecificDatumReader(Schema writer, Schema reader, SpecificData data)

Construct given writer's schema, reader's schema, and a SpecificData.

SpecificDatumReaderback to summary
public SpecificDatumReader(SpecificData data)

Construct given a SpecificData.

Method Detail

findStringClassback to summary
protected Class<T> findStringClass(Schema schema)

Overrides org.apache.avro.generic.GenericDatumReader.findStringClass.

Doc from org.apache.avro.generic.GenericDatumReader.findStringClass.

Determines the class to used to represent a string Schema. By default uses GenericData#STRING_PROP to determine whether Utf8 or String is used. Subclasses may override for alternate representations.

Annotations
@Override
getPropAsClassback to summary
private Class<T> getPropAsClass(Schema schema, String prop)
getSpecificDataback to summary
public SpecificData getSpecificData()

Return the contained SpecificData.

readFieldback to summary
protected void readField(Object record, Schema.Field field, Object oldDatum, ResolvingDecoder in, Object state) throws IOException

Overrides org.apache.avro.generic.GenericDatumReader.readField.

Doc from org.apache.avro.generic.GenericDatumReader.readField.

Called to read a single field of a record. May be overridden for more efficient or alternate implementations.

Annotations
@Override
readRecordback to summary
protected Object readRecord(Object old, Schema expected, ResolvingDecoder in) throws IOException

Overrides org.apache.avro.generic.GenericDatumReader.readRecord.

Doc from org.apache.avro.generic.GenericDatumReader.readRecord.

Called to read a record instance. May be overridden for alternate record representations.

Annotations
@Override
setSchemaback to summary
public void setSchema(Schema actual)

Overrides org.apache.avro.generic.GenericDatumReader.setSchema.

Implements org.apache.avro.io.DatumReader.setSchema.

Doc from org.apache.avro.io.DatumReader.setSchema.

Set the writer's schema.

Annotations
@Override