Package com.linkedin.venice.fastclient

Class StatsAvroGenericStoreClient<K,V>

java.lang.Object

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

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

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

All Implemented Interfaces:

AvroGenericReadComputeStoreClient<K,V>, AvroGenericStoreClient<K,V>, java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

StatsAvroSpecificStoreClient

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

This class is in charge of all the metric emissions per request.

Constructor Summary

Constructors

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

Method Summary

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

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

close, compute, getClientConfig, getKeySchema, getLatestValueSchema, 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

get

Constructor Detail

StatsAvroGenericStoreClient

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

Method Detail

get

protected java.util.concurrent.CompletableFuture<V> get(GetRequestContext requestContext,
                                                        K key)
                                                 throws VeniceClientException

Overrides:

get in class DelegatingAvroStoreClient<K,V>

Throws:

VeniceClientException

streamingBatchGet

protected void streamingBatchGet(BatchGetRequestContext<K,V> requestContext,
                                 java.util.Set<K> keys,
                                 StreamingCallback<K,V> callback)

Overrides:

streamingBatchGet in class DelegatingAvroStoreClient<K,V>

compute

public void compute(ComputeRequestContext<K,V> requestContext,
                    ComputeRequestWrapper computeRequestWrapper,
                    java.util.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