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>, Closeable, 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(InternalAvroStoreClient<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, startWithExceptionThrownWhenFail, streamingBatchGet

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

getRaw, getStreamingCallback

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, computeAggregation

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

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

Constructor Details

SpecificRetriableStoreClient

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