Package com.linkedin.venice.client.store

Class VsonGenericStoreClientImpl<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.VsonGenericStoreClientImpl<K,V>

All Implemented Interfaces:

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

@Deprecated
public class VsonGenericStoreClientImpl<K,V>
extends AvroGenericStoreClientImpl<K,V>

Deprecated.

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
VsonGenericStoreClientImpl(TransportClient transportClient, ClientConfig clientConfig)	Deprecated.

Method Summary

Modifier and Type	Method	Description
ComputeRequestBuilder<K>	compute(Optional<ClientStats> stats, AvroGenericReadComputeStoreClient computeStoreClient)	Deprecated.
protected RecordSerializer<K>	createKeySerializer()	Deprecated. Clients using different protocols for deserialized data (e.g VSON, Proto, etc) can override this method to serialize the respective POJO to Avro bytes
protected RecordDeserializer<V>	getDeserializerFromFactory(org.apache.avro.Schema writer, org.apache.avro.Schema reader)	Deprecated.
protected AbstractAvroStoreClient<K,V>	getStoreClientForSchemaReader()	Deprecated. To avoid cycle dependency, we need to initialize another store client for schema reader.

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

getDataRecordDeserializer, toString

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

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

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

batchGet, get, streamingBatchGet

Constructor Details

VsonGenericStoreClientImpl

public VsonGenericStoreClientImpl(TransportClient transportClient,
 ClientConfig clientConfig)

Deprecated.

Method Details

getStoreClientForSchemaReader

protected AbstractAvroStoreClient<K,V> getStoreClientForSchemaReader()

Deprecated.

Description copied from class: AvroGenericStoreClientImpl

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

Overrides:

getStoreClientForSchemaReader in class AvroGenericStoreClientImpl<K,V>

Returns:

getDeserializerFromFactory

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

Deprecated.

Overrides:

getDeserializerFromFactory in class AvroGenericStoreClientImpl<K,V>

createKeySerializer

protected RecordSerializer<K> createKeySerializer()

Deprecated.

Description copied from class: AbstractAvroStoreClient

Clients using different protocols for deserialized data (e.g VSON, Proto, etc) can override this method to serialize the respective POJO to Avro bytes

Overrides:

createKeySerializer in class AbstractAvroStoreClient<K,V>

Returns:

A serializer for key objects to Avro bytes

compute

public ComputeRequestBuilder<K> compute(Optional<ClientStats> stats,
 AvroGenericReadComputeStoreClient computeStoreClient)
                                 throws VeniceClientException

Deprecated.

Throws:

VeniceClientException