AvroStoreDeserializerCache (venice API)

java.lang.Object

com.linkedin.venice.serialization.AvroStoreDeserializerCache<T>

All Implemented Interfaces:: StoreDeserializerCache<T>

public class AvroStoreDeserializerCache<T> extends Object implements StoreDeserializerCache<T>

Container for the deserializers of a single store.

Constructor Summary

Constructors

Constructor

Description

AvroStoreDeserializerCache(ReadOnlySchemaRepository schemaRepository, String storeName, boolean fastAvroEnabled)

AvroStoreDeserializerCache(SchemaReader schemaReader)

AvroStoreDeserializerCache(IntFunction<org.apache.avro.Schema> schemaGetter, BiFunction<org.apache.avro.Schema,org.apache.avro.Schema,RecordDeserializer<T>> deserializerGetter)

Constructor that allows custom deserializer factory to be provided.
Method Summary

Modifier and Type

Method

Description

RecordDeserializer<T>

getDeserializer(int writerSchemaId)

RecordDeserializer<T>

getDeserializer(int writerSchemaId, int readerSchemaId)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- AvroStoreDeserializerCache
  
  public AvroStoreDeserializerCache(ReadOnlySchemaRepository schemaRepository, String storeName, boolean fastAvroEnabled)
- AvroStoreDeserializerCache
  
  public AvroStoreDeserializerCache(SchemaReader schemaReader)
- AvroStoreDeserializerCache
  
  public AvroStoreDeserializerCache(IntFunction<org.apache.avro.Schema> schemaGetter, BiFunction<org.apache.avro.Schema,org.apache.avro.Schema,RecordDeserializer<T>> deserializerGetter)
  
  Constructor that allows custom deserializer factory to be provided. This enables support for custom serialization formats (e.g., Protocol Buffers) while reusing the caching infrastructure.
  
  Parameters:
  
  schemaGetter - Function to retrieve schema by schema ID
  
  deserializerGetter - Function to create deserializer given writer and reader schemas
Method Details
- getDeserializer
  
  public RecordDeserializer<T> getDeserializer(int writerSchemaId, int readerSchemaId)
  
  Specified by:
  
  getDeserializer in interface StoreDeserializerCache<T>
- getDeserializer
  
  public RecordDeserializer<T> getDeserializer(int writerSchemaId)
  
  Specified by:
  
  getDeserializer in interface StoreDeserializerCache<T>