public class SpecificDatumReader<T> extends GenericDatumReader<T>
DatumReader
for generated Java classes.Constructor and Description |
---|
SpecificDatumReader() |
SpecificDatumReader(Class<T> c)
Construct for reading instances of a class.
|
SpecificDatumReader(Schema schema)
Construct where the writer's and reader's schemas are the same.
|
SpecificDatumReader(Schema writer,
Schema reader)
Construct given writer's and reader's schema.
|
SpecificDatumReader(Schema writer,
Schema reader,
SpecificData data)
Construct given writer's schema, reader's schema, and a
SpecificData . |
SpecificDatumReader(SpecificData data)
Construct given a
SpecificData . |
Modifier and Type | Method and Description |
---|---|
protected Class |
findStringClass(Schema schema)
Determines the class to used to represent a string Schema.
|
SpecificData |
getSpecificData()
Return the contained
SpecificData . |
protected void |
readField(Object r,
Schema.Field f,
Object oldDatum,
ResolvingDecoder in,
Object state)
Called to read a single field of a record.
|
void |
setSchema(Schema actual)
Set the writer's schema.
|
addToArray, addToMap, convert, createBytes, createEnum, createFixed, createFixed, createString, getData, getExpected, getResolver, getSchema, newArray, newInstanceFromString, newMap, newRecord, peekArray, read, read, readArray, readBytes, readBytes, readEnum, readFixed, readInt, readMap, readMapKey, readRecord, readString, readString, readWithConversion, readWithoutConversion, setExpected, skip
public SpecificDatumReader()
public SpecificDatumReader(Class<T> c)
public SpecificDatumReader(Schema schema)
public SpecificDatumReader(Schema writer, Schema reader)
public SpecificDatumReader(Schema writer, Schema reader, SpecificData data)
SpecificData
.public SpecificDatumReader(SpecificData data)
SpecificData
.public SpecificData getSpecificData()
SpecificData
.public void setSchema(Schema actual)
DatumReader
setSchema
in interface DatumReader<T>
setSchema
in class GenericDatumReader<T>
protected Class findStringClass(Schema schema)
GenericDatumReader
GenericData.STRING_PROP
to determine whether Utf8
or
String
is used. Subclasses may override for alternate
representations.findStringClass
in class GenericDatumReader<T>
protected void readField(Object r, Schema.Field f, Object oldDatum, ResolvingDecoder in, Object state) throws IOException
GenericDatumReader
readField
in class GenericDatumReader<T>
IOException
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.