Package com.linkedin.venice.client.store

Class DelegatingStoreClient<K,V>

java.lang.Object

com.linkedin.venice.client.store.InternalAvroStoreClient<K,V>

com.linkedin.venice.client.store.DelegatingStoreClient<K,V>

All Implemented Interfaces:

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

Direct Known Subclasses:

RetriableStoreClient, StatTrackingStoreClient

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

Constructor Summary

Constructors

Constructor	Description
DelegatingStoreClient(InternalAvroStoreClient<K,V> innerStoreClient)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Map<K,V>>	batchGet(Set<K> keys)	Get the values associated with the given keys and return them in a map of keys to values.
void	close()	Release the internal resources.
void	compute(ComputeRequestWrapper computeRequestWrapper, Set<K> keys, org.apache.avro.Schema resultSchema, StreamingCallback<K,ComputeGenericRecord> callback, long preRequestTimeInNS)
ComputeRequestBuilder<K>	compute(Optional<ClientStats> stats, Optional<ClientStats> streamingStats, AvroGenericReadComputeStoreClient computeStoreClient, long preRequestTimeInNS)
void	computeWithKeyPrefixFilter(byte[] keyPrefix, ComputeRequestWrapper computeRequestWrapper, StreamingCallback<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> callback)
CompletableFuture<V>	get(K key, Optional<ClientStats> stats, long preRequestTimeInNS)
Executor	getDeserializationExecutor()
InternalAvroStoreClient<K,V>	getInnerStoreClient()
org.apache.avro.Schema	getKeySchema()	Deprecated.
org.apache.avro.Schema	getLatestValueSchema()	Deprecated.
CompletableFuture<byte[]>	getRaw(String requestPath, Optional<ClientStats> stats, long preRequestTimeInNS)
SchemaReader	getSchemaReader()
String	getStoreName()
boolean	isProjectionFieldValidationEnabled()
void	start()
void	streamingBatchGet(Set<K> keys, StreamingCallback<K,V> callback)	Streaming interface for AvroGenericStoreClient.batchGet(Set).

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

get, getRaw

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

get, streamingBatchGet

Constructor Details

DelegatingStoreClient

public DelegatingStoreClient(InternalAvroStoreClient<K,V> innerStoreClient)

Method Details

getInnerStoreClient

public InternalAvroStoreClient<K,V> getInnerStoreClient()

getSchemaReader

public SchemaReader getSchemaReader()

isProjectionFieldValidationEnabled

public boolean isProjectionFieldValidationEnabled()

compute

public ComputeRequestBuilder<K> compute(Optional<ClientStats> stats,
 Optional<ClientStats> streamingStats,
 AvroGenericReadComputeStoreClient computeStoreClient,
 long preRequestTimeInNS)
                                 throws VeniceClientException

Throws:

VeniceClientException

compute

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

Throws:

VeniceClientException

batchGet

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

Description copied from interface: AvroGenericStoreClient

Get the values associated with the given keys and return them in a map of keys to values. Note that the returned map will only contain entries for the keys which have a value associated with them.

Returns:

Throws:

VeniceClientException

streamingBatchGet

public void streamingBatchGet(Set<K> keys,
 StreamingCallback<K,V> callback)
                       throws VeniceClientException

Description copied from interface: AvroGenericStoreClient

Streaming interface for AvroGenericStoreClient.batchGet(Set). You can find more info in StreamingCallback.

Throws:

VeniceClientException

start

public void start()
           throws VeniceClientException

Throws:

VeniceClientException

close

public void close()

Description copied from interface: AvroGenericStoreClient

Release the internal resources.

getStoreName

public String getStoreName()

getKeySchema

@Deprecated
public org.apache.avro.Schema getKeySchema()

Deprecated.

Description copied from interface: AvroGenericStoreClient

Get key schema.

getLatestValueSchema

@Deprecated
public org.apache.avro.Schema getLatestValueSchema()

Deprecated.

Description copied from interface: AvroGenericStoreClient

Get the latest value schema known in current store client. This function doesn't guarantee it will return the latest schema if you add a new value schema when current store client is running.

get

public CompletableFuture<V> get(K key,
 Optional<ClientStats> stats,
 long preRequestTimeInNS)
                         throws VeniceClientException

Specified by:

get in class InternalAvroStoreClient<K,V>

Throws:

VeniceClientException

getRaw

public CompletableFuture<byte[]> getRaw(String requestPath,
 Optional<ClientStats> stats,
 long preRequestTimeInNS)

Specified by:

getRaw in class InternalAvroStoreClient<K,V>

getDeserializationExecutor

public Executor getDeserializationExecutor()

Overrides:

getDeserializationExecutor in class InternalAvroStoreClient<K,V>

computeWithKeyPrefixFilter

public void computeWithKeyPrefixFilter(byte[] keyPrefix,
 ComputeRequestWrapper computeRequestWrapper,
 StreamingCallback<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> callback)

Specified by:

computeWithKeyPrefixFilter in interface AvroGenericReadComputeStoreClient<K,V>

Overrides:

computeWithKeyPrefixFilter in class InternalAvroStoreClient<K,V>