public interface AvroSchemaServiceManager
Schema
together with its String representation.
Helps to substitute the default implementation of Schema
Generation using Custom Avro schema generator
Provide a custom bean definition of AvroSchemaServiceManager
and mark
it as @Primary to override the default implementationModifier and Type | Method and Description |
---|---|
org.apache.avro.io.DatumReader<Object> |
getDatumReader(Class<? extends Object> type,
org.apache.avro.Schema schema,
org.apache.avro.Schema writerSchema)
get
DatumReader . |
org.apache.avro.io.DatumWriter<Object> |
getDatumWriter(Class<? extends Object> type,
org.apache.avro.Schema schema)
get
DatumWriter . |
org.apache.avro.Schema |
getSchema(Class<?> clazz)
get
Schema . |
Object |
readData(Class<? extends Object> targetClass,
byte[] payload,
org.apache.avro.Schema readerSchema,
org.apache.avro.Schema writerSchema)
read data from avro type payload
DatumReader . |
org.apache.avro.Schema getSchema(Class<?> clazz)
Schema
.clazz
- Class
for which schema generation is requiredorg.apache.avro.io.DatumWriter<Object> getDatumWriter(Class<? extends Object> type, org.apache.avro.Schema schema)
DatumWriter
.type
- Class
of java object which needs to be serializedschema
- Schema
of object which needs to be serializedorg.apache.avro.io.DatumReader<Object> getDatumReader(Class<? extends Object> type, org.apache.avro.Schema schema, org.apache.avro.Schema writerSchema)
DatumReader
.type
- Class
of java object which needs to be serializedschema
- Schema
default schema of object which needs to be de-serializedwriterSchema
- Schema
writerSchema provided at run timeObject readData(Class<? extends Object> targetClass, byte[] payload, org.apache.avro.Schema readerSchema, org.apache.avro.Schema writerSchema) throws IOException
DatumReader
.targetClass
- Class
of java object which needs to be serializedpayload
- byte
serialized payload of object which needs to be de-serializedreaderSchema
- Schema
readerSchema of object which needs to be de-serializedwriterSchema
- Schema
writerSchema used to while serializing payloadIOException
- in case of errorCopyright © 2021 Pivotal Software, Inc.. All rights reserved.