Package com.linkedin.davinci.consumer

Class VeniceChangelogConsumerClientFactory

java.lang.Object

com.linkedin.davinci.consumer.VeniceChangelogConsumerClientFactory

public class VeniceChangelogConsumerClientFactory
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	VeniceChangelogConsumerClientFactory.ViewClassGetter

Field Summary

Fields

Modifier and Type	Field	Description
protected VeniceChangelogConsumerClientFactory.ViewClassGetter	viewClassGetter

Constructor Summary

Constructors

Constructor	Description
VeniceChangelogConsumerClientFactory(ChangelogClientConfig globalChangelogClientConfig, io.tehuti.metrics.MetricsRepository metricsRepository)

Method Summary

Modifier and Type	Method	Description
void	deregisterClient(String consumerName)	Removes client from the map, so it be cleaned up by Garbage Collection
<K, V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(String storeName)
<K, V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(String storeName, String consumerId)
<K, V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(String storeName, String consumerId, Class<K> keyClass, Class<V> valueClass, org.apache.avro.Schema valueSchema)
<K, V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(String storeName, String consumerId, Class<V> valueClass)
<K, V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(String storeName)	Default method to create a VeniceChangelogConsumer given a storeName.
<K, V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(String storeName, String consumerId)
<K, V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(String storeName, String consumerId, Class<V> valueClass)	Creates a VeniceChangelogConsumer with consumer id.
<K, V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(String storeName, String consumerId, Class<V> valueClass, String viewNameOverride)
protected static PubSubConsumerAdapter	getPubSubConsumer(ChangelogClientConfig changelogClientConfig, PubSubMessageDeserializer pubSubMessageDeserializer, String consumerName)
<K, V> VeniceChangelogConsumer<K,V>	getVersionSpecificChangelogConsumer(String storeName, int storeVersion, String consumerId)	Subscribes to a specific version of a Venice store.
protected void	setConsumer(PubSubConsumerAdapter consumer)
protected void	setD2ControllerClient(D2ControllerClient d2ControllerClient)
protected void	setViewClassGetter(VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter)

Methods inherited from class java.lang.Object

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

Field Details

viewClassGetter

protected VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter

Constructor Details

VeniceChangelogConsumerClientFactory

public VeniceChangelogConsumerClientFactory(ChangelogClientConfig globalChangelogClientConfig,
 io.tehuti.metrics.MetricsRepository metricsRepository)

Method Details

setD2ControllerClient

protected void setD2ControllerClient(D2ControllerClient d2ControllerClient)

setConsumer

protected void setConsumer(PubSubConsumerAdapter consumer)

getChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getChangelogConsumer(String storeName)

Default method to create a VeniceChangelogConsumer given a storeName.

getChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getChangelogConsumer(String storeName,
 String consumerId)

getChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getChangelogConsumer(String storeName,
 String consumerId,
 Class<V> valueClass)

Creates a VeniceChangelogConsumer with consumer id. This is used to create multiple consumers so that each consumer can only subscribe to certain partitions. Multiple such consumers can work in parallel.

getChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getChangelogConsumer(String storeName,
 String consumerId,
 Class<V> valueClass,
 String viewNameOverride)

getBootstrappingChangelogConsumer

public <K,
V>
BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(String storeName)

getBootstrappingChangelogConsumer

public <K,
V>
BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(String storeName,
 String consumerId,
 Class<K> keyClass,
 Class<V> valueClass,
 org.apache.avro.Schema valueSchema)

Parameters:

keyClass - The SpecificRecord class for your key

valueClass - The SpecificRecord class for your value

valueSchema - The Schema for your values

getBootstrappingChangelogConsumer

public <K,
V>
BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(String storeName,
 String consumerId,
 Class<V> valueClass)

getBootstrappingChangelogConsumer

public <K,
V>
BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(String storeName,
 String consumerId)

getVersionSpecificChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getVersionSpecificChangelogConsumer(String storeName,
 int storeVersion,
 String consumerId)

Subscribes to a specific version of a Venice store. This is only intended for internal use.

getPubSubConsumer

protected static PubSubConsumerAdapter getPubSubConsumer(ChangelogClientConfig changelogClientConfig,
 PubSubMessageDeserializer pubSubMessageDeserializer,
 String consumerName)

setViewClassGetter

protected void setViewClassGetter(VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter)

deregisterClient

public void deregisterClient(String consumerName)

Removes client from the map, so it be cleaned up by Garbage Collection