Package com.linkedin.venice.beam.consumer

Interface VeniceChangelogConsumerProvider<K,V>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

LocalVeniceChangelogConsumerProvider

public interface VeniceChangelogConsumerProvider<K,V>
extends java.io.Serializable

Interface to provide a configured VeniceChangelogConsumer instance.

Method Summary

Modifier and Type	Method	Description
VeniceChangelogConsumer<K,V>	getVeniceChangelogConsumer(java.lang.String storeName)
VeniceChangelogConsumer<K,V>	getVeniceChangelogConsumer(java.lang.String storeName, java.lang.String consumerId)

Method Detail

getVeniceChangelogConsumer

VeniceChangelogConsumer<K,V> getVeniceChangelogConsumer(java.lang.String storeName)
                                                       throws java.lang.NoSuchMethodException,
                                                              java.lang.reflect.InvocationTargetException,
                                                              java.lang.InstantiationException,
                                                              java.lang.IllegalAccessException

Throws:

java.lang.NoSuchMethodException

java.lang.reflect.InvocationTargetException

java.lang.InstantiationException

java.lang.IllegalAccessException

getVeniceChangelogConsumer

VeniceChangelogConsumer<K,V> getVeniceChangelogConsumer(java.lang.String storeName,
                                                              java.lang.String consumerId)
                                                       throws java.lang.NoSuchMethodException,
                                                              java.lang.reflect.InvocationTargetException,
                                                              java.lang.InstantiationException,
                                                              java.lang.IllegalAccessException

Throws:

java.lang.NoSuchMethodException

java.lang.reflect.InvocationTargetException

java.lang.InstantiationException

java.lang.IllegalAccessException