public class ThriftData
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 |
ThriftData() |
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 ThriftData |
get()
Return the singleton instance.
|
protected org.apache.avro.Schema |
getEnumSchema(Object datum) |
Object |
getField(Object r,
String name,
int pos) |
protected Object |
getField(Object record,
String name,
int pos,
Object state) |
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 thrift generated class.
|
protected String |
getSchemaName(Object datum) |
protected boolean |
isBytes(Object datum) |
protected boolean |
isEnum(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, getFastReaderBuilder, getFixedSchema, getNewRecordSupplier, getPrimitiveTypeCache, hashCode, hashCodeAdd, induce, instanceOf, isArray, isBoolean, isDouble, isFastReaderEnabled, isFixed, isFloat, isInteger, isLong, isMap, isString, newArray, newMap, resolveUnion, setFastReaderEnabled, setStringType, toString, toString, validate
public static ThriftData 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 String getSchemaName(Object datum)
getSchemaName
in class org.apache.avro.generic.GenericData
protected boolean isRecord(Object datum)
isRecord
in class org.apache.avro.generic.GenericData
protected boolean isEnum(Object datum)
isEnum
in class org.apache.avro.generic.GenericData
protected org.apache.avro.Schema getEnumSchema(Object datum)
getEnumSchema
in class org.apache.avro.generic.GenericData
protected boolean isBytes(Object datum)
isBytes
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 org.apache.avro.Schema getRecordSchema(Object record)
getRecordSchema
in class org.apache.avro.generic.GenericData
public org.apache.avro.Schema getSchema(Class c)
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.