public abstract class AbstractAvroSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer> implements AvroSchemaRegistry
This abstract class can be extended to implement concrete classes capable of (de)serializing generic avro objects across a Topology. The methods in the AvroSchemaRegistry interface specify how schemas can be mapped to unique identifiers and vice versa. Implementations based on pre-defining schemas or utilizing an external schema registry are provided.
| Constructor and Description |
|---|
AbstractAvroSerializer() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.avro.generic.GenericContainer |
read(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Input input,
Class<org.apache.avro.generic.GenericContainer> someClass) |
void |
write(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Output output,
org.apache.avro.generic.GenericContainer record) |
copy, getAcceptsNull, isImmutable, setAcceptsNull, setGenerics, setImmutableclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetFingerprint, getSchemapublic void write(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Output output,
org.apache.avro.generic.GenericContainer record)
write in class com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer>public org.apache.avro.generic.GenericContainer read(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Input input,
Class<org.apache.avro.generic.GenericContainer> someClass)
read in class com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer>Copyright © 2021 The Apache Software Foundation. All rights reserved.