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>, java.io.Closeable, java.lang.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, java.util.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 Detail

AvroBlackHoleResponseStoreClientImpl

public AvroBlackHoleResponseStoreClientImpl(TransportClient transportClient,
                                            ClientConfig clientConfig)

Method Detail

compute

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