Package com.linkedin.venice.client.store

Class RetriableStoreClient<K,V>

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>

All Implemented Interfaces:

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

Direct Known Subclasses:

SpecificRetriableStoreClient

public class RetriableStoreClient<K,V>
extends DelegatingStoreClient<K,V>

TODO: make retry work for compute request.

Constructor Summary

Constructors

Constructor	Description
RetriableStoreClient(InternalAvroStoreClient<K,V> innerStoreClient, ClientConfig clientConfig)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Map<K,V>>	batchGet(Set<K> keys)	Adding retry logic on router error as this method returning the completion stage value.
CompletableFuture<V>	get(K key)	Adding retry logic on router error as this method returning the completion stage value.
static Executor	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

get, streamingBatchGet

Constructor Details

RetriableStoreClient

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

Method Details

getDefaultRetryExecutor

public static Executor getDefaultRetryExecutor()

get

public CompletableFuture<V> get(K key)
                         throws VeniceClientException

Adding retry logic on router error as this method returning the completion stage value.

Specified by:

get in interface AvroGenericStoreClient<K,V>

Overrides:

get in class InternalAvroStoreClient<K,V>

Returns:

Throws:

VeniceClientException

batchGet

public CompletableFuture<Map<K,V>> batchGet(Set<K> keys)
                                     throws VeniceClientException

Adding retry logic on router error as this method returning the completion stage value.

Specified by:

batchGet in interface AvroGenericStoreClient<K,V>

Overrides:

batchGet in class DelegatingStoreClient<K,V>

Returns:

Throws:

VeniceClientException