Package org.apache.avro.protobuf
Class ProtobufDatumReader<T>
java.lang.Object
org.apache.avro.generic.GenericDatumReader<T>
org.apache.avro.protobuf.ProtobufDatumReader<T>
- All Implemented Interfaces:
org.apache.avro.io.DatumReader<T>
public class ProtobufDatumReader<T>
extends org.apache.avro.generic.GenericDatumReader<T>
DatumReader
for generated Protobuf
classes.-
Constructor Summary
ConstructorsModifierConstructorDescriptionProtobufDatumReader
(org.apache.avro.Schema schema) Construct where the writer's and reader's schemas are the same.ProtobufDatumReader
(org.apache.avro.Schema writer, org.apache.avro.Schema reader) Construct given writer's and reader's schema.protected
ProtobufDatumReader
(org.apache.avro.Schema writer, org.apache.avro.Schema reader, ProtobufData data) -
Method Summary
Modifier and TypeMethodDescriptionprotected Object
createEnum
(String symbol, org.apache.avro.Schema schema) protected Object
protected Object
readRecord
(Object old, org.apache.avro.Schema expected, org.apache.avro.io.ResolvingDecoder in) Methods inherited from class org.apache.avro.generic.GenericDatumReader
addToArray, addToMap, convert, createBytes, createFixed, createFixed, createString, findStringClass, getData, getExpected, getResolver, getSchema, newArray, newInstanceFromString, newMap, newRecord, peekArray, read, read, readArray, readBytes, readEnum, readField, readFixed, readInt, readMap, readMapKey, readString, readString, readWithConversion, readWithoutConversion, setExpected, setSchema, skip
-
Constructor Details
-
ProtobufDatumReader
public ProtobufDatumReader() -
ProtobufDatumReader
-
ProtobufDatumReader
public ProtobufDatumReader(org.apache.avro.Schema schema) Construct where the writer's and reader's schemas are the same. -
ProtobufDatumReader
public ProtobufDatumReader(org.apache.avro.Schema writer, org.apache.avro.Schema reader) Construct given writer's and reader's schema. -
ProtobufDatumReader
protected ProtobufDatumReader(org.apache.avro.Schema writer, org.apache.avro.Schema reader, ProtobufData data)
-
-
Method Details
-
readRecord
protected Object readRecord(Object old, org.apache.avro.Schema expected, org.apache.avro.io.ResolvingDecoder in) throws IOException - Overrides:
readRecord
in classorg.apache.avro.generic.GenericDatumReader<T>
- Throws:
IOException
-
createEnum
- Overrides:
createEnum
in classorg.apache.avro.generic.GenericDatumReader<T>
-
readBytes
- Overrides:
readBytes
in classorg.apache.avro.generic.GenericDatumReader<T>
- Throws:
IOException
-