Package org.apache.avro.protobuf
Class ProtobufData
java.lang.Object
org.apache.avro.generic.GenericData
org.apache.avro.protobuf.ProtobufData
public class ProtobufData
extends org.apache.avro.generic.GenericData
Utilities for serializing Protobuf data in Avro format.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.avro.generic.GenericData
org.apache.avro.generic.GenericData.AbstractArray<T>, org.apache.avro.generic.GenericData.Array<T>, org.apache.avro.generic.GenericData.EnumSymbol, org.apache.avro.generic.GenericData.Fixed, org.apache.avro.generic.GenericData.InstanceSupplier, org.apache.avro.generic.GenericData.Record, org.apache.avro.generic.GenericData.StringType
-
Field Summary
Fields inherited from class org.apache.avro.generic.GenericData
FAST_READER_PROP, STRING_PROP, STRING_TYPE_STRING
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.avro.io.DatumReader
createDatumReader
(org.apache.avro.Schema schema) org.apache.avro.io.DatumWriter
createDatumWriter
(org.apache.avro.Schema schema) static ProtobufData
get()
Return the singleton instance.protected Object
getNamespace
(com.google.protobuf.Descriptors.FileDescriptor fd, com.google.protobuf.Descriptors.Descriptor containing) protected org.apache.avro.Schema
getRecordSchema
(Object record) protected Object
getRecordState
(Object r, org.apache.avro.Schema s) org.apache.avro.Schema
getSchema
(com.google.protobuf.Descriptors.Descriptor descriptor) org.apache.avro.Schema
getSchema
(com.google.protobuf.Descriptors.EnumDescriptor d) org.apache.avro.Schema
getSchema
(com.google.protobuf.Descriptors.FieldDescriptor f) org.apache.avro.Schema
Return a record schema given a protobuf message class.protected boolean
protected boolean
protected boolean
void
protected void
Methods inherited from class org.apache.avro.generic.GenericData
addLogicalTypeConversion, compare, compare, compareMaps, createDatumReader, createEnum, createFixed, createFixed, createString, deepCopy, getArrayAsCollection, getClassLoader, getConversionByClass, getConversionByClass, getConversionFor, getConversions, getDefaultValue, getEnumSchema, getFastReaderBuilder, getFixedSchema, getNewRecordSupplier, getPrimitiveTypeCache, getSchemaName, hashCode, induce, instanceOf, isBoolean, isDouble, isEnum, isFastReaderEnabled, isFixed, isFloat, isInteger, isLong, isMap, isString, newArray, newMap, resolveUnion, setFastReaderEnabled, setStringType, toString, toString, validate
-
Constructor Details
-
ProtobufData
protected ProtobufData()
-
-
Method Details
-
get
Return the singleton instance. -
createDatumReader
public org.apache.avro.io.DatumReader createDatumReader(org.apache.avro.Schema schema) - Overrides:
createDatumReader
in classorg.apache.avro.generic.GenericData
-
createDatumWriter
public org.apache.avro.io.DatumWriter createDatumWriter(org.apache.avro.Schema schema) - Overrides:
createDatumWriter
in classorg.apache.avro.generic.GenericData
-
setField
- Overrides:
setField
in classorg.apache.avro.generic.GenericData
-
getField
- Overrides:
getField
in classorg.apache.avro.generic.GenericData
-
setField
- Overrides:
setField
in classorg.apache.avro.generic.GenericData
-
getField
- Overrides:
getField
in classorg.apache.avro.generic.GenericData
-
getRecordState
- Overrides:
getRecordState
in classorg.apache.avro.generic.GenericData
-
isRecord
- Overrides:
isRecord
in classorg.apache.avro.generic.GenericData
-
newRecord
- Overrides:
newRecord
in classorg.apache.avro.generic.GenericData
-
isArray
- Overrides:
isArray
in classorg.apache.avro.generic.GenericData
-
isBytes
- Overrides:
isBytes
in classorg.apache.avro.generic.GenericData
-
getRecordSchema
- Overrides:
getRecordSchema
in classorg.apache.avro.generic.GenericData
-
getSchema
Return a record schema given a protobuf message class. -
getSchema
public org.apache.avro.Schema getSchema(com.google.protobuf.Descriptors.Descriptor descriptor) -
getNamespace
public String getNamespace(com.google.protobuf.Descriptors.FileDescriptor fd, com.google.protobuf.Descriptors.Descriptor containing) -
getSchema
public org.apache.avro.Schema getSchema(com.google.protobuf.Descriptors.FieldDescriptor f) -
getSchema
public org.apache.avro.Schema getSchema(com.google.protobuf.Descriptors.EnumDescriptor d)
-