Package com.linkedin.venice.fastclient

Class DispatchingAvroSpecificStoreClient<K,V extends org.apache.avro.specific.SpecificRecord>

java.lang.Object

com.linkedin.venice.fastclient.InternalAvroStoreClient<K,V>

com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient<K,V>

com.linkedin.venice.fastclient.DispatchingAvroSpecificStoreClient<K,V>

All Implemented Interfaces:

AvroGenericReadComputeStoreClient<K,V>, AvroGenericStoreClient<K,V>, AvroSpecificStoreClient<K,V>, Closeable, AutoCloseable

public class DispatchingAvroSpecificStoreClient<K,V extends org.apache.avro.specific.SpecificRecord>
extends DispatchingAvroGenericStoreClient<K,V>
implements AvroSpecificStoreClient<K,V>

Field Summary

Fields inherited from class com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient

metadata, storeDeserializerCache

Constructor Summary

Constructors

Constructor	Description
DispatchingAvroSpecificStoreClient(StoreMetadata metadata, ClientConfig config)

Method Summary

Modifier and Type	Method	Description
protected RecordDeserializer<V>	getDataRecordDeserializer(int schemaId)

Methods inherited from class com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient

close, compute, get, getClientConfig, getKeySchema, getKeySerializer, getLatestValueSchema, getMultiGetResponseRecordDeserializer, getSchemaReader, getStoreMetadata, getStoreName, start, streamingBatchGet

Methods inherited from class com.linkedin.venice.fastclient.InternalAvroStoreClient

batchGet, batchGet, compute, computeWithKeyPrefixFilter, get, isProjectionFieldValidationEnabled, streamingBatchGet, streamingBatchGet, streamingBatchGet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient

compute, compute, compute, compute, computeAggregation

Methods inherited from interface com.linkedin.venice.client.store.AvroGenericStoreClient

batchGet, close, get, get, getKeySchema, getLatestValueSchema, getStoreName, start, streamingBatchGet, streamingBatchGet

Constructor Details

DispatchingAvroSpecificStoreClient

public DispatchingAvroSpecificStoreClient(StoreMetadata metadata,
 ClientConfig config)

Method Details

getDataRecordDeserializer

protected RecordDeserializer<V> getDataRecordDeserializer(int schemaId)
                                                   throws VeniceClientException

Overrides:

getDataRecordDeserializer in class DispatchingAvroGenericStoreClient<K,V extends org.apache.avro.specific.SpecificRecord>

Throws:

VeniceClientException