public class ProtobufData
extends org.apache.avro.generic.GenericData
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
Modifier | Constructor and Description |
---|---|
protected |
ProtobufData() |
Modifier and Type | Method and Description |
---|---|
org.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.
|
Object |
getField(Object r,
String name,
int pos) |
protected Object |
getField(Object record,
String name,
int pos,
Object state) |
String |
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(Class c)
Return a record schema given a protobuf message class.
|
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) |
protected boolean |
isArray(Object datum) |
protected boolean |
isBytes(Object datum) |
protected boolean |
isRecord(Object datum) |
Object |
newRecord(Object old,
org.apache.avro.Schema schema) |
void |
setField(Object r,
String n,
int pos,
Object value) |
protected void |
setField(Object record,
String name,
int position,
Object value,
Object state) |
addLogicalTypeConversion, compare, compare, compareMaps, createDatumReader, createEnum, createFixed, createFixed, createString, deepCopy, getArrayAsCollection, getClassLoader, getConversionByClass, getConversionByClass, getConversionFor, getConversions, getDefaultValue, getEnumSchema, getFastReaderBuilder, getFixedSchema, getNewRecordSupplier, getPrimitiveTypeCache, getSchemaName, hashCode, hashCodeAdd, induce, instanceOf, isBoolean, isDouble, isEnum, isFastReaderEnabled, isFixed, isFloat, isInteger, isLong, isMap, isString, newArray, newMap, resolveUnion, setFastReaderEnabled, setStringType, toString, toString, validate
public static ProtobufData get()
public org.apache.avro.io.DatumReader createDatumReader(org.apache.avro.Schema schema)
createDatumReader
in class org.apache.avro.generic.GenericData
public org.apache.avro.io.DatumWriter createDatumWriter(org.apache.avro.Schema schema)
createDatumWriter
in class org.apache.avro.generic.GenericData
public void setField(Object r, String n, int pos, Object value)
setField
in class org.apache.avro.generic.GenericData
public Object getField(Object r, String name, int pos)
getField
in class org.apache.avro.generic.GenericData
protected void setField(Object record, String name, int position, Object value, Object state)
setField
in class org.apache.avro.generic.GenericData
protected Object getField(Object record, String name, int pos, Object state)
getField
in class org.apache.avro.generic.GenericData
protected Object getRecordState(Object r, org.apache.avro.Schema s)
getRecordState
in class org.apache.avro.generic.GenericData
protected boolean isRecord(Object datum)
isRecord
in class org.apache.avro.generic.GenericData
public Object newRecord(Object old, org.apache.avro.Schema schema)
newRecord
in class org.apache.avro.generic.GenericData
protected boolean isArray(Object datum)
isArray
in class org.apache.avro.generic.GenericData
protected boolean isBytes(Object datum)
isBytes
in class org.apache.avro.generic.GenericData
protected org.apache.avro.Schema getRecordSchema(Object record)
getRecordSchema
in class org.apache.avro.generic.GenericData
public org.apache.avro.Schema getSchema(Class c)
public org.apache.avro.Schema getSchema(com.google.protobuf.Descriptors.Descriptor descriptor)
public String getNamespace(com.google.protobuf.Descriptors.FileDescriptor fd, com.google.protobuf.Descriptors.Descriptor containing)
public org.apache.avro.Schema getSchema(com.google.protobuf.Descriptors.FieldDescriptor f)
public org.apache.avro.Schema getSchema(com.google.protobuf.Descriptors.EnumDescriptor d)
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.