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, validatepublic static ProtobufData get()
public org.apache.avro.io.DatumReader createDatumReader(org.apache.avro.Schema schema)
createDatumReader in class org.apache.avro.generic.GenericDatapublic org.apache.avro.io.DatumWriter createDatumWriter(org.apache.avro.Schema schema)
createDatumWriter in class org.apache.avro.generic.GenericDatapublic void setField(Object r, String n, int pos, Object value)
setField in class org.apache.avro.generic.GenericDatapublic Object getField(Object r, String name, int pos)
getField in class org.apache.avro.generic.GenericDataprotected void setField(Object record, String name, int position, Object value, Object state)
setField in class org.apache.avro.generic.GenericDataprotected Object getField(Object record, String name, int pos, Object state)
getField in class org.apache.avro.generic.GenericDataprotected Object getRecordState(Object r, org.apache.avro.Schema s)
getRecordState in class org.apache.avro.generic.GenericDataprotected boolean isRecord(Object datum)
isRecord in class org.apache.avro.generic.GenericDatapublic Object newRecord(Object old, org.apache.avro.Schema schema)
newRecord in class org.apache.avro.generic.GenericDataprotected boolean isArray(Object datum)
isArray in class org.apache.avro.generic.GenericDataprotected boolean isBytes(Object datum)
isBytes in class org.apache.avro.generic.GenericDataprotected org.apache.avro.Schema getRecordSchema(Object record)
getRecordSchema in class org.apache.avro.generic.GenericDatapublic 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.