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.DatumReadercreateDatumReader(org.apache.avro.Schema schema) org.apache.avro.io.DatumWritercreateDatumWriter(org.apache.avro.Schema schema) static ProtobufDataget()Return the singleton instance.protected ObjectgetNamespace(com.google.protobuf.Descriptors.FileDescriptor fd, com.google.protobuf.Descriptors.Descriptor containing) protected org.apache.avro.SchemagetRecordSchema(Object record) protected ObjectgetRecordState(Object r, org.apache.avro.Schema s) org.apache.avro.SchemagetSchema(com.google.protobuf.Descriptors.Descriptor descriptor) org.apache.avro.SchemagetSchema(com.google.protobuf.Descriptors.EnumDescriptor d) org.apache.avro.SchemagetSchema(com.google.protobuf.Descriptors.FieldDescriptor f) org.apache.avro.SchemaReturn a record schema given a protobuf message class.protected booleanprotected booleanprotected booleanvoidprotected voidMethods 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:
createDatumReaderin classorg.apache.avro.generic.GenericData
-
createDatumWriter
public org.apache.avro.io.DatumWriter createDatumWriter(org.apache.avro.Schema schema) - Overrides:
createDatumWriterin classorg.apache.avro.generic.GenericData
-
setField
- Overrides:
setFieldin classorg.apache.avro.generic.GenericData
-
getField
- Overrides:
getFieldin classorg.apache.avro.generic.GenericData
-
setField
- Overrides:
setFieldin classorg.apache.avro.generic.GenericData
-
getField
- Overrides:
getFieldin classorg.apache.avro.generic.GenericData
-
getRecordState
- Overrides:
getRecordStatein classorg.apache.avro.generic.GenericData
-
isRecord
- Overrides:
isRecordin classorg.apache.avro.generic.GenericData
-
newRecord
- Overrides:
newRecordin classorg.apache.avro.generic.GenericData
-
isArray
- Overrides:
isArrayin classorg.apache.avro.generic.GenericData
-
isBytes
- Overrides:
isBytesin classorg.apache.avro.generic.GenericData
-
getRecordSchema
- Overrides:
getRecordSchemain 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)
-