public class ProtobufDatumReader<T> extends GenericDatumReader<T>
DatumReader
for generated Protobuf
classes.Modifier | Constructor and Description |
---|---|
|
ProtobufDatumReader() |
|
ProtobufDatumReader(Class<T> c) |
|
ProtobufDatumReader(Schema schema)
Construct where the writer's and reader's schemas are the same.
|
|
ProtobufDatumReader(Schema writer,
Schema reader)
Construct given writer's and reader's schema.
|
protected |
ProtobufDatumReader(Schema writer,
Schema reader,
ProtobufData data) |
Modifier and Type | Method and Description |
---|---|
protected Object |
createEnum(String symbol,
Schema schema) |
protected Object |
readBytes(Object old,
Decoder in) |
protected Object |
readRecord(Object old,
Schema expected,
ResolvingDecoder in) |
addToArray, addToMap, createBytes, createFixed, createFixed, createString, getData, getExpected, getResolver, getSchema, newArray, newMap, newRecord, peekArray, read, read, readArray, readBytes, readEnum, readFixed, readInt, readMap, readMapKey, readString, readString, setExpected, setSchema, skip
public ProtobufDatumReader()
public ProtobufDatumReader(Schema schema)
public ProtobufDatumReader(Schema writer, Schema reader)
protected ProtobufDatumReader(Schema writer, Schema reader, ProtobufData data)
protected Object readRecord(Object old, Schema expected, ResolvingDecoder in) throws IOException
readRecord
in class GenericDatumReader<T>
IOException
protected Object createEnum(String symbol, Schema schema)
createEnum
in class GenericDatumReader<T>
protected Object readBytes(Object old, Decoder in) throws IOException
readBytes
in class GenericDatumReader<T>
IOException
Copyright © 2009-2013 The Apache Software Foundation. All Rights Reserved.