Package com.linkedin.venice.fastclient

Class LoadControlledAvroSpecificStoreClient<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.LoadControlledAvroGenericStoreClient<K,V>

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

All Implemented Interfaces:

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

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

Field Summary

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

RATE_EXCEEDED_EXCEPTION

Constructor Summary

Constructors

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

Method Summary

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

compute, get, streamingBatchGet

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

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

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

Constructor Details

LoadControlledAvroSpecificStoreClient

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