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.protectedProtobufDatumReader(org.apache.avro.Schema writer, org.apache.avro.Schema reader, ProtobufData data) -
Method Summary
Modifier and TypeMethodDescriptionprotected ObjectcreateEnum(String symbol, org.apache.avro.Schema schema) protected Objectprotected ObjectreadRecord(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:
readRecordin classorg.apache.avro.generic.GenericDatumReader<T>- Throws:
IOException
-
createEnum
- Overrides:
createEnumin classorg.apache.avro.generic.GenericDatumReader<T>
-
readBytes
- Overrides:
readBytesin classorg.apache.avro.generic.GenericDatumReader<T>- Throws:
IOException
-