Package com.linkedin.venice.fastclient

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

java.lang.Object

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

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

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

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

All Implemented Interfaces:

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

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

Field Summary

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

MULTI_KEY_LONG_TAIL_RETRY_STATS_PREFIX, SINGLE_KEY_LONG_TAIL_RETRY_STATS_PREFIX

Constructor Summary

Constructors

Constructor	Description
RetriableAvroSpecificStoreClient(InternalAvroStoreClient<K,V> delegate, ClientConfig clientConfig, TimeoutProcessor timeoutProcessor)

Method Summary

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

close, compute, get, streamingBatchGet

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

compute, getClientConfig, getKeySchema, getLatestValueSchema, getSchemaReader, getStoreName, start

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

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

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

Constructor Details

RetriableAvroSpecificStoreClient

public RetriableAvroSpecificStoreClient(InternalAvroStoreClient<K,V> delegate,
 ClientConfig clientConfig,
 TimeoutProcessor timeoutProcessor)