Package com.linkedin.venice.client.store

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

java.lang.Object

com.linkedin.venice.client.store.InternalAvroStoreClient<K,V>

com.linkedin.venice.client.store.DelegatingStoreClient<K,V>

com.linkedin.venice.client.store.RetriableStoreClient<K,V>

com.linkedin.venice.client.store.SpecificRetriableStoreClient<K,V>

Type Parameters:

V -

All Implemented Interfaces:

AvroGenericReadComputeStoreClient<K,V>, AvroGenericStoreClient<K,V>, AvroSpecificStoreClient<K,V>, java.io.Closeable, java.lang.AutoCloseable

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

This class is necessary because Venice needs to maintain a separate interface: AvroSpecificStoreClient.

Constructor Summary

Constructors

Constructor	Description
SpecificRetriableStoreClient(SpecificStatTrackingStoreClient<K,V> innerStoreClient, ClientConfig clientConfig)

Method Summary

Methods inherited from class com.linkedin.venice.client.store.RetriableStoreClient

batchGet, get, getDefaultRetryExecutor

Methods inherited from class com.linkedin.venice.client.store.DelegatingStoreClient

close, compute, compute, computeWithKeyPrefixFilter, get, getDeserializationExecutor, getInnerStoreClient, getKeySchema, getLatestValueSchema, getRaw, getSchemaReader, getStoreName, isProjectionFieldValidationEnabled, start, streamingBatchGet

Methods inherited from class com.linkedin.venice.client.store.InternalAvroStoreClient

getRaw

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

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

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

Constructor Detail

SpecificRetriableStoreClient

public SpecificRetriableStoreClient(SpecificStatTrackingStoreClient<K,V> innerStoreClient,
                                    ClientConfig clientConfig)