public class ProtobufDatumReader<T>
extends org.apache.avro.generic.GenericDatumReader<T>
DatumReader
for generated Protobuf
classes.Modifier | Constructor and Description |
---|---|
|
ProtobufDatumReader() |
|
ProtobufDatumReader(Class<T> c) |
|
ProtobufDatumReader(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) |
Modifier and Type | Method and Description |
---|---|
protected Object |
createEnum(String symbol,
org.apache.avro.Schema schema) |
protected Object |
readBytes(Object old,
org.apache.avro.io.Decoder in) |
protected Object |
readRecord(Object old,
org.apache.avro.Schema expected,
org.apache.avro.io.ResolvingDecoder in) |
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
public ProtobufDatumReader()
public ProtobufDatumReader(org.apache.avro.Schema schema)
public ProtobufDatumReader(org.apache.avro.Schema writer, org.apache.avro.Schema reader)
protected ProtobufDatumReader(org.apache.avro.Schema writer, org.apache.avro.Schema reader, ProtobufData data)
protected Object readRecord(Object old, org.apache.avro.Schema expected, org.apache.avro.io.ResolvingDecoder in) throws IOException
readRecord
in class org.apache.avro.generic.GenericDatumReader<T>
IOException
protected Object createEnum(String symbol, org.apache.avro.Schema schema)
createEnum
in class org.apache.avro.generic.GenericDatumReader<T>
protected Object readBytes(Object old, org.apache.avro.io.Decoder in) throws IOException
readBytes
in class org.apache.avro.generic.GenericDatumReader<T>
IOException
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.