Package com.linkedin.venice.fastclient

Class LoadControlledAvroGenericStoreClient<K,V>

java.lang.Object

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

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

LoadControlledAvroSpecificStoreClient

public class LoadControlledAvroGenericStoreClient<K,V>
extends DelegatingAvroStoreClient<K,V>

This class is used to control the load on the store from the client perspective.

Field Summary

Fields

Modifier and Type	Field	Description
static final VeniceClientRateExceededException	RATE_EXCEEDED_EXCEPTION

Constructor Summary

Constructors

Constructor	Description
LoadControlledAvroGenericStoreClient(InternalAvroStoreClient<K,V> delegate, ClientConfig clientConfig)

Method Summary

Modifier and Type	Method	Description
protected void	compute(ComputeRequestContext<K,V> requestContext, ComputeRequestWrapper computeRequestWrapper, Set<K> keys, org.apache.avro.Schema resultSchema, StreamingCallback<K,ComputeGenericRecord> callback, long preRequestTimeInNS)
protected CompletableFuture<V>	get(GetRequestContext<K> requestContext, K key)
protected void	streamingBatchGet(BatchGetRequestContext<K,V> requestContext, Set<K> keys, StreamingCallback<K,V> callback)

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

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

get

Field Details

RATE_EXCEEDED_EXCEPTION

public static final VeniceClientRateExceededException RATE_EXCEEDED_EXCEPTION

Constructor Details

LoadControlledAvroGenericStoreClient

public LoadControlledAvroGenericStoreClient(InternalAvroStoreClient<K,V> delegate,
 ClientConfig clientConfig)

Method Details

get

protected CompletableFuture<V> get(GetRequestContext<K> requestContext,
 K key)
                            throws VeniceClientException

Overrides:

get in class DelegatingAvroStoreClient<K,V>

Throws:

VeniceClientException

streamingBatchGet

protected void streamingBatchGet(BatchGetRequestContext<K,V> requestContext,
 Set<K> keys,
 StreamingCallback<K,V> callback)
                          throws VeniceClientException

Overrides:

streamingBatchGet in class DelegatingAvroStoreClient<K,V>

Throws:

VeniceClientException

compute

protected void compute(ComputeRequestContext<K,V> requestContext,
 ComputeRequestWrapper computeRequestWrapper,
 Set<K> keys,
 org.apache.avro.Schema resultSchema,
 StreamingCallback<K,ComputeGenericRecord> callback,
 long preRequestTimeInNS)
                throws VeniceClientException

Overrides:

compute in class DelegatingAvroStoreClient<K,V>

Throws:

VeniceClientException