Package com.linkedin.venice.client.store

Class AvroBlackHoleResponseStoreClientImpl<K,V>

java.lang.Object

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

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

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

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

All Implemented Interfaces:

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

public class AvroBlackHoleResponseStoreClientImpl<K,V>
extends AvroGenericStoreClientImpl<K,V>

This class should be used for experiments only. It is able to send out requests, but responses from Venice Router will be ignored. TODO: Currently it only works for compute streaming. Need to support single-get, batch-get and regular read compute.

Field Summary

Fields inherited from class com.linkedin.venice.client.store.AbstractAvroStoreClient

B64_FORMAT, computeRequestClientKeySerializer, keySerializer, multiGetRequestSerializer, needSchemaReader, TYPE_COMPUTE, TYPE_STORAGE

Constructor Summary

Constructors

Constructor	Description
AvroBlackHoleResponseStoreClientImpl(TransportClient transportClient, ClientConfig clientConfig)

Method Summary

Modifier and Type	Method	Description
void	compute(ComputeRequestWrapper computeRequestWrapper, Set<K> keys, org.apache.avro.Schema resultSchema, StreamingCallback<K,ComputeGenericRecord> callback, long preRequestTimeInNS)

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

getDataRecordDeserializer, getDeserializerFromFactory, getStoreClientForSchemaReader, toString

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

close, createKeySerializer, get, getClientConfig, getComputeRequestPath, getDefaultDeserializationExecutor, getDeserializationExecutor, getKeySchema, getKeySerializerForRequest, getKeySerializerWithoutRetry, getLatestValueSchema, getRaw, getReaderSchema, getRequestPathByKey, getSchemaReader, getStoreName, getTransportClient, handleCallbackForEmptyKeySet, init, isProjectionFieldValidationEnabled, setAsyncStoreInitSleepIntervalMs, start, streamingBatchGet, tryToDeserializeWithVerboseLogging

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

computeWithKeyPrefixFilter, get, getRaw

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

compute, compute, compute, compute

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

batchGet, get, streamingBatchGet

Constructor Details

AvroBlackHoleResponseStoreClientImpl

public AvroBlackHoleResponseStoreClientImpl(TransportClient transportClient,
 ClientConfig clientConfig)

Method Details

compute

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

Specified by:

compute in interface AvroGenericReadComputeStoreClient<K,V>

Overrides:

compute in class AbstractAvroStoreClient<K,V>

Throws:

VeniceClientException