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, skippublic 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>IOExceptionprotected 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>IOExceptionCopyright © 2009–2023 The Apache Software Foundation. All rights reserved.