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> Closeable
,AutoCloseable
- Direct Known Subclasses:
AvroBlackHoleResponseStoreClientImpl
,VsonGenericStoreClientImpl
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
ConstructorsConstructorDescriptionAvroGenericStoreClientImpl
(TransportClient transportClient, boolean needSchemaReader, ClientConfig clientConfig) AvroGenericStoreClientImpl
(TransportClient transportClient, ClientConfig clientConfig) -
Method Summary
Modifier and TypeMethodDescriptiongetDataRecordDeserializer
(int writerSchemaId) protected RecordDeserializer<V>
getDeserializerFromFactory
(org.apache.avro.Schema writer, org.apache.avro.Schema reader) protected AbstractAvroStoreClient<K,
V> To avoid cycle dependency, we need to initialize another store client for schema reader.toString()
Methods inherited from class com.linkedin.venice.client.store.AbstractAvroStoreClient
close, compute, createKeySerializer, get, getClientConfig, getComputeRequestPath, getDefaultDeserializationExecutor, getDeserializationExecutor, getKeySchema, getLatestValueSchema, getRaw, getReaderSchema, getRequestPathByKey, getSchemaReader, getStoreName, getTransportClient, handleCallbackForEmptyKeySet, isProjectionFieldValidationEnabled, start, startWithExceptionThrownWhenFail, 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
-
AvroGenericStoreClientImpl
-
AvroGenericStoreClientImpl
public AvroGenericStoreClientImpl(TransportClient transportClient, boolean needSchemaReader, ClientConfig clientConfig)
-
-
Method Details
-
getStoreClientForSchemaReader
To avoid cycle dependency, we need to initialize another store client for schema reader.- Specified by:
getStoreClientForSchemaReader
in classAbstractAvroStoreClient<K,
V> - Returns:
-
getDataRecordDeserializer
public RecordDeserializer<V> getDataRecordDeserializer(int writerSchemaId) throws VeniceClientException - Specified by:
getDataRecordDeserializer
in classAbstractAvroStoreClient<K,
V> - Throws:
VeniceClientException
-
getDeserializerFromFactory
protected RecordDeserializer<V> getDeserializerFromFactory(org.apache.avro.Schema writer, org.apache.avro.Schema reader) -
toString
- Overrides:
toString
in classAbstractAvroStoreClient<K,
V>
-