public class ReflectAvroDatumProvider<T> extends Object implements AvroDatumProvider<T>
REGISTRY_AVRO_DATUM_PROVIDER_CONFIG_PARAM, REGISTRY_USE_SPECIFIC_AVRO_READER_CONFIG_PARAM
Constructor and Description |
---|
ReflectAvroDatumProvider() |
ReflectAvroDatumProvider(Class<T> clazz) |
Modifier and Type | Method and Description |
---|---|
org.apache.avro.io.DatumReader<T> |
createDatumReader(org.apache.avro.Schema schema) |
org.apache.avro.io.DatumWriter<T> |
createDatumWriter(T data,
org.apache.avro.Schema schema) |
org.apache.avro.Schema |
toSchema(T data) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure
public org.apache.avro.io.DatumWriter<T> createDatumWriter(T data, org.apache.avro.Schema schema)
createDatumWriter
in interface AvroDatumProvider<T>
public org.apache.avro.io.DatumReader<T> createDatumReader(org.apache.avro.Schema schema)
createDatumReader
in interface AvroDatumProvider<T>
public org.apache.avro.Schema toSchema(T data)
toSchema
in interface AvroDatumProvider<T>
Copyright © 2020 Red Hat. All rights reserved.