Package com.linkedin.venice.serialization.avro
-
Class Summary Class Description AvroSpecificStoreDeserializerCache<V extends org.apache.avro.specific.SpecificRecord> ChunkedKeySuffixSerializer ChunkedValueManifestSerializer InternalAvroSpecificSerializer<SPECIFIC_RECORD extends org.apache.avro.specific.SpecificRecord> Serializer for translating a versioned protocol of Avro records.KafkaValueSerializer Serializer for the Avro-based kafka protocol defined in:KafkaMessageEnvelope
This class needs to be defined explicitly, rather than just instantiating aInternalAvroSpecificSerializer
because it is used as a config passed to the Kafka producer.OptimizedKafkaValueSerializer This class is to reuse the original array for put payload of each message to reduce the unnecessary byte array allocation.SchemaPresenceChecker This class helps checks presence of a schema version in ZK.VeniceAvroKafkaSerializer This class is a thin wrapper ofAvroSerializer
andAvroGenericDeserializer
.VeniceSpecificDatumReader<T> -
Enum Summary Enum Description AvroProtocolDefinition This enum lays out the basic specs of the various stateful protocols used in Venice.