Package com.linkedin.venice.client.factory

Class CachingVeniceStoreClientFactory

java.lang.Object

com.linkedin.venice.client.factory.CachingVeniceStoreClientFactory

All Implemented Interfaces:

VeniceStoreClientFactory

public class CachingVeniceStoreClientFactory
extends Object
implements VeniceStoreClientFactory

Nested Class Summary

Nested classes/interfaces inherited from interface com.linkedin.venice.client.factory.VeniceStoreClientFactory

VeniceStoreClientFactory.ClientConfigUpdater

Constructor Summary

Constructors

Constructor	Description
CachingVeniceStoreClientFactory(ClientConfig clientConfig)
CachingVeniceStoreClientFactory(ClientConfig clientConfig, VeniceStoreClientGlobalConfig globalConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
<K, V> AvroGenericStoreClient<K,V>	getAndStartAvroGenericStoreClient(String storeName)
<K, V> AvroGenericStoreClient<K,V>	getAndStartAvroGenericStoreClient(String storeName, VeniceStoreClientFactory.ClientConfigUpdater configUpdater)	create a generic client along with customized client configs.
<K, V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V>	getAndStartAvroSpecificStoreClient(String storeName, Class<V> specificRecordClass)
<K, V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V>	getAndStartAvroSpecificStoreClient(String storeName, Class<V> specificRecordClass, VeniceStoreClientFactory.ClientConfigUpdater configUpdater)

Methods inherited from class java.lang.Object

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

Constructor Details

CachingVeniceStoreClientFactory

public CachingVeniceStoreClientFactory(ClientConfig clientConfig)

CachingVeniceStoreClientFactory

public CachingVeniceStoreClientFactory(ClientConfig clientConfig,
 VeniceStoreClientGlobalConfig globalConfig)

Method Details

getAndStartAvroGenericStoreClient

public <K,
V> AvroGenericStoreClient<K,V> getAndStartAvroGenericStoreClient(String storeName)

Specified by:

getAndStartAvroGenericStoreClient in interface VeniceStoreClientFactory

getAndStartAvroGenericStoreClient

public <K,
V> AvroGenericStoreClient<K,V> getAndStartAvroGenericStoreClient(String storeName,
 VeniceStoreClientFactory.ClientConfigUpdater configUpdater)

Description copied from interface: VeniceStoreClientFactory

create a generic client along with customized client configs. This is only for sophisticated use cases. Do not use it if you are not familiar with these configs. e.g. client = veniceStoreClientFactory.getAndStartAvroGenericStoreClient(storeName, (config) -> config.setVsonClient(true));

Specified by:

getAndStartAvroGenericStoreClient in interface VeniceStoreClientFactory

Returns:

getAndStartAvroSpecificStoreClient

public <K,
V extends org.apache.avro.specific.SpecificRecord>
AvroSpecificStoreClient<K,V> getAndStartAvroSpecificStoreClient(String storeName,
 Class<V> specificRecordClass)

Specified by:

getAndStartAvroSpecificStoreClient in interface VeniceStoreClientFactory

getAndStartAvroSpecificStoreClient

public <K,
V extends org.apache.avro.specific.SpecificRecord>
AvroSpecificStoreClient<K,V> getAndStartAvroSpecificStoreClient(String storeName,
 Class<V> specificRecordClass,
 VeniceStoreClientFactory.ClientConfigUpdater configUpdater)

Specified by:

getAndStartAvroSpecificStoreClient in interface VeniceStoreClientFactory

close

public void close()

Specified by:

close in interface VeniceStoreClientFactory