Package com.linkedin.venice.client.store

Class AvroGenericStoreClientImpl<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>

All Implemented Interfaces:

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

Direct Known Subclasses:

AvroBlackHoleResponseStoreClientImpl, VsonGenericStoreClientImpl

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

AvroGenericStoreClient implementation for Avro generic type.

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
AvroGenericStoreClientImpl(TransportClient transportClient, boolean needSchemaReader, ClientConfig clientConfig)
AvroGenericStoreClientImpl(TransportClient transportClient, ClientConfig clientConfig)

Method Summary

Modifier and Type	Method	Description
RecordDeserializer<V>	getDataRecordDeserializer(int writerSchemaId)
protected RecordDeserializer<V>	getDeserializerFromFactory(org.apache.avro.Schema writer, org.apache.avro.Schema reader)
protected AbstractAvroStoreClient<K,V>	getStoreClientForSchemaReader()	To avoid cycle dependency, we need to initialize another store client for schema reader.
java.lang.String	toString()

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

close, compute, 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

AvroGenericStoreClientImpl

public AvroGenericStoreClientImpl(TransportClient transportClient,
                                  ClientConfig clientConfig)

AvroGenericStoreClientImpl

public AvroGenericStoreClientImpl(TransportClient transportClient,
                                  boolean needSchemaReader,
                                  ClientConfig clientConfig)

Method Detail

getStoreClientForSchemaReader

protected AbstractAvroStoreClient<K,V> getStoreClientForSchemaReader()

To avoid cycle dependency, we need to initialize another store client for schema reader.

Specified by:

getStoreClientForSchemaReader in class AbstractAvroStoreClient<K,V>

Returns:

getDataRecordDeserializer

public RecordDeserializer<V> getDataRecordDeserializer(int writerSchemaId)
                                                throws VeniceClientException

Specified by:

getDataRecordDeserializer in class AbstractAvroStoreClient<K,V>

Throws:

VeniceClientException

getDeserializerFromFactory

protected RecordDeserializer<V> getDeserializerFromFactory(org.apache.avro.Schema writer,
                                                           org.apache.avro.Schema reader)

toString

public java.lang.String toString()

Overrides:

toString in class AbstractAvroStoreClient<K,V>