Package com.linkedin.davinci.client.factory

Class CachingDaVinciClientFactory

java.lang.Object

com.linkedin.davinci.client.factory.CachingDaVinciClientFactory

All Implemented Interfaces:

DaVinciClientFactory, VersionSpecificDaVinciClientFactory, Closeable, AutoCloseable

public class CachingDaVinciClientFactory
extends Object
implements DaVinciClientFactory, VersionSpecificDaVinciClientFactory, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	CachingDaVinciClientFactory.DaVinciClientConstructor

Field Summary

Fields

Modifier and Type	Field	Description
protected final VeniceProperties	backendConfig
protected boolean	closed
protected final Map<String,DaVinciConfig>	configs
protected final com.linkedin.d2.balancer.D2Client	d2Client
protected final ICProvider	icProvider
protected final List<DaVinciClient>	isolatedClients
protected final Optional<Set<String>>	managedClients
protected final io.tehuti.metrics.MetricsRepository	metricsRepository
protected final Map<String,DaVinciClient>	sharedClients
protected final Map<String,DaVinciClient>	versionSpecificClients

Constructor Summary

Constructors

Constructor	Description
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, String clusterDiscoveryD2ServiceName, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig)
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, String clusterDiscoveryD2ServiceName, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig, Optional<Set<String>> managedClients)
CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client, String clusterDiscoveryD2ServiceName, io.tehuti.metrics.MetricsRepository metricsRepository, VeniceProperties backendConfig, Optional<Set<String>> managedClients, ICProvider icProvider, Executor readChunkExecutorForLargeRequest)

Method Summary

Modifier and Type	Method	Description
void	close()
<K, V> DaVinciClient<K,V>	getAndStartGenericAvroClient(String storeName, DaVinciConfig config)
<K, V> DaVinciClient<K,V>	getAndStartGenericAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)
<K, V> DaVinciClient<K,V>	getAndStartGenericAvroClient(String storeName, String viewName, DaVinciConfig config)
<K, V> SeekableDaVinciClient<K,V>	getAndStartGenericSeekableAvroClient(String storeName, DaVinciConfig config)
<K, V extends org.apache.avro.specific.SpecificRecord> DaVinciClient<K,V>	getAndStartSpecificAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)
<K, V extends org.apache.avro.specific.SpecificRecord> DaVinciClient<K,V>	getAndStartSpecificAvroClient(String storeName, String viewName, DaVinciConfig config, Class<V> valueClass)
<K, V> SeekableDaVinciClient<K,V>	getAndStartVersionSpecificGenericAvroClient(String storeName, int storeVersion, DaVinciConfig config)
<K, V> SeekableDaVinciClient<K,V>	getAndStartVersionSpecificGenericAvroClient(String storeName, int storeVersion, String viewName, DaVinciConfig config)
VeniceProperties	getBackendConfig()
protected DaVinciClient	getClient(String storeName, Integer storeVersion, String viewName, DaVinciConfig config, Class valueClass, CachingDaVinciClientFactory.DaVinciClientConstructor clientConstructor, Class clientClass, boolean startClient)
protected DaVinciClient	getClient(String storeName, String viewName, DaVinciConfig config, Class valueClass, CachingDaVinciClientFactory.DaVinciClientConstructor clientConstructor, Class clientClass, boolean startClient)
<K, V> DaVinciClient<K,V>	getGenericAvroClient(String storeName, DaVinciConfig config)
<K, V> DaVinciClient<K,V>	getGenericAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)
<K, V> DaVinciClient<K,V>	getGenericAvroClient(String storeName, String viewName, DaVinciConfig config)
<K, V> SeekableDaVinciClient<K,V>	getGenericSeekableAvroClient(String storeName, DaVinciConfig config)
<K, V extends org.apache.avro.specific.SpecificRecord> DaVinciClient<K,V>	getSpecificAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)
<K, V extends org.apache.avro.specific.SpecificRecord> DaVinciClient<K,V>	getSpecificAvroClient(String storeName, String viewName, DaVinciConfig config, Class<V> valueClass)
<K, V> SeekableDaVinciClient<K,V>	getSpecificSeekableAvroClient(String storeName, DaVinciConfig config, Class<V> valueClass)
<K, V> SeekableDaVinciClient<K,V>	getVersionSpecificGenericAvroClient(String storeName, int storeVersion, DaVinciConfig config)
<K, V> SeekableDaVinciClient<K,V>	getVersionSpecificGenericAvroClient(String storeName, int storeVersion, String viewName, DaVinciConfig config)

Methods inherited from class java.lang.Object

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

Field Details

closed

protected boolean closed

d2Client

protected final com.linkedin.d2.balancer.D2Client d2Client

metricsRepository

protected final io.tehuti.metrics.MetricsRepository metricsRepository

backendConfig

protected final VeniceProperties backendConfig

managedClients

protected final Optional<Set<String>> managedClients

icProvider

protected final ICProvider icProvider

sharedClients

protected final Map<String,DaVinciClient> sharedClients

versionSpecificClients

protected final Map<String,DaVinciClient> versionSpecificClients

isolatedClients

protected final List<DaVinciClient> isolatedClients

configs

protected final Map<String,DaVinciConfig> configs

Constructor Details

CachingDaVinciClientFactory

public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 String clusterDiscoveryD2ServiceName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig)

CachingDaVinciClientFactory

public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 String clusterDiscoveryD2ServiceName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients)

CachingDaVinciClientFactory

public CachingDaVinciClientFactory(com.linkedin.d2.balancer.D2Client d2Client,
 String clusterDiscoveryD2ServiceName,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients,
 ICProvider icProvider,
 Executor readChunkExecutorForLargeRequest)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getGenericAvroClient

public <K,
V> DaVinciClient<K,V> getGenericAvroClient(String storeName,
 DaVinciConfig config)

Specified by:

getGenericAvroClient in interface DaVinciClientFactory

getGenericAvroClient

public <K,
V> DaVinciClient<K,V> getGenericAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)

getAndStartGenericAvroClient

public <K,
V> DaVinciClient<K,V> getAndStartGenericAvroClient(String storeName,
 DaVinciConfig config)

Specified by:

getAndStartGenericAvroClient in interface DaVinciClientFactory

getAndStartGenericAvroClient

public <K,
V> DaVinciClient<K,V> getAndStartGenericAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)

getGenericAvroClient

public <K,
V> DaVinciClient<K,V> getGenericAvroClient(String storeName,
 String viewName,
 DaVinciConfig config)

Specified by:

getGenericAvroClient in interface DaVinciClientFactory

getAndStartGenericAvroClient

public <K,
V> DaVinciClient<K,V> getAndStartGenericAvroClient(String storeName,
 String viewName,
 DaVinciConfig config)

Specified by:

getAndStartGenericAvroClient in interface DaVinciClientFactory

getSpecificAvroClient

public <K,
V extends org.apache.avro.specific.SpecificRecord>
DaVinciClient<K,V> getSpecificAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)

Specified by:

getSpecificAvroClient in interface DaVinciClientFactory

getAndStartSpecificAvroClient

public <K,
V extends org.apache.avro.specific.SpecificRecord>
DaVinciClient<K,V> getAndStartSpecificAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)

Specified by:

getAndStartSpecificAvroClient in interface DaVinciClientFactory

getSpecificAvroClient

public <K,
V extends org.apache.avro.specific.SpecificRecord>
DaVinciClient<K,V> getSpecificAvroClient(String storeName,
 String viewName,
 DaVinciConfig config,
 Class<V> valueClass)

Specified by:

getSpecificAvroClient in interface DaVinciClientFactory

getAndStartSpecificAvroClient

public <K,
V extends org.apache.avro.specific.SpecificRecord>
DaVinciClient<K,V> getAndStartSpecificAvroClient(String storeName,
 String viewName,
 DaVinciConfig config,
 Class<V> valueClass)

Specified by:

getAndStartSpecificAvroClient in interface DaVinciClientFactory

getVersionSpecificGenericAvroClient

public <K,
V> SeekableDaVinciClient<K,V> getVersionSpecificGenericAvroClient(String storeName,
 int storeVersion,
 DaVinciConfig config)

Specified by:

getVersionSpecificGenericAvroClient in interface VersionSpecificDaVinciClientFactory

getAndStartVersionSpecificGenericAvroClient

public <K,
V> SeekableDaVinciClient<K,V> getAndStartVersionSpecificGenericAvroClient(String storeName,
 int storeVersion,
 DaVinciConfig config)

Specified by:

getAndStartVersionSpecificGenericAvroClient in interface VersionSpecificDaVinciClientFactory

getVersionSpecificGenericAvroClient

public <K,
V> SeekableDaVinciClient<K,V> getVersionSpecificGenericAvroClient(String storeName,
 int storeVersion,
 String viewName,
 DaVinciConfig config)

Specified by:

getVersionSpecificGenericAvroClient in interface VersionSpecificDaVinciClientFactory

getAndStartVersionSpecificGenericAvroClient

public <K,
V> SeekableDaVinciClient<K,V> getAndStartVersionSpecificGenericAvroClient(String storeName,
 int storeVersion,
 String viewName,
 DaVinciConfig config)

Specified by:

getAndStartVersionSpecificGenericAvroClient in interface VersionSpecificDaVinciClientFactory

getBackendConfig

public VeniceProperties getBackendConfig()

getClient

protected DaVinciClient getClient(String storeName,
 String viewName,
 DaVinciConfig config,
 Class valueClass,
 CachingDaVinciClientFactory.DaVinciClientConstructor clientConstructor,
 Class clientClass,
 boolean startClient)

getClient

protected DaVinciClient getClient(String storeName,
 Integer storeVersion,
 String viewName,
 DaVinciConfig config,
 Class valueClass,
 CachingDaVinciClientFactory.DaVinciClientConstructor clientConstructor,
 Class clientClass,
 boolean startClient)

Parameters:

storeVersion - Pass in a non-null value if you want a version specific DaVinciClient

getGenericSeekableAvroClient

public <K,
V> SeekableDaVinciClient<K,V> getGenericSeekableAvroClient(String storeName,
 DaVinciConfig config)

getAndStartGenericSeekableAvroClient

public <K,
V> SeekableDaVinciClient<K,V> getAndStartGenericSeekableAvroClient(String storeName,
 DaVinciConfig config)

getSpecificSeekableAvroClient

public <K,
V> SeekableDaVinciClient<K,V> getSpecificSeekableAvroClient(String storeName,
 DaVinciConfig config,
 Class<V> valueClass)