Package com.linkedin.venice.views

Class ChangeCaptureView

java.lang.Object

com.linkedin.venice.views.VeniceView

com.linkedin.venice.views.ChangeCaptureView

public class ChangeCaptureView
extends VeniceView

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHANGE_CAPTURE_TOPIC_SUFFIX
static final String	CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME

Fields inherited from class com.linkedin.venice.views.VeniceView

props, storeName, VIEW_NAME_SEPARATOR, VIEW_STORE_PREFIX, viewParameters

Constructor Summary

Constructors

Constructor	Description
ChangeCaptureView(Properties props, String storeName, Map<String,String> viewParameters)

Method Summary

Modifier and Type	Method	Description
String	composeTopicName(int version)
Map<String,VeniceProperties>	getTopicNamesAndConfigsForVersion(int version)	Implementations should override to return a map of topicName:topic Configs relevant for topic materialization (things like partition count, RF, etc.) TODO: Come up with list of config names that should be parsed by VeniceAdmin to pass along to TopicManager.
String	getWriterClassName()	Implementations should return the fully specified class name for the component VeniceViewWriter implementation.
VeniceWriterOptions.Builder	getWriterOptionsBuilder(String viewTopicName, Version version)
void	validateConfigs(Store store)	Validate that the configs set up for this view for this store are valid.

Methods inherited from class com.linkedin.venice.views.VeniceView

close, getStoreName, getStoreNameFromViewStoreName, getViewNameFromViewStoreName, getViewStoreName, isViewStore, isViewTopic, parseStoreAndViewFromViewTopic, parseStoreFromViewTopic, parseVersionFromViewTopic

Methods inherited from class java.lang.Object

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

Field Details

CHANGE_CAPTURE_TOPIC_SUFFIX

public static final String CHANGE_CAPTURE_TOPIC_SUFFIX

See Also:

• Constant Field Values

CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME

public static final String CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME

See Also:

• Constant Field Values

Constructor Details

ChangeCaptureView

public ChangeCaptureView(Properties props,
 String storeName,
 Map<String,String> viewParameters)

Method Details

getWriterOptionsBuilder

public VeniceWriterOptions.Builder getWriterOptionsBuilder(String viewTopicName,
 Version version)

Overrides:

getWriterOptionsBuilder in class VeniceView

getTopicNamesAndConfigsForVersion

public Map<String,VeniceProperties> getTopicNamesAndConfigsForVersion(int version)

Description copied from class: VeniceView

Implementations should override to return a map of topicName:topic Configs relevant for topic materialization (things like partition count, RF, etc.) TODO: Come up with list of config names that should be parsed by VeniceAdmin to pass along to TopicManager.

Overrides:

getTopicNamesAndConfigsForVersion in class VeniceView

Returns:

a map keyed by the name of the topic to be created and the configs which should be applied for that creation

composeTopicName

public String composeTopicName(int version)

Overrides:

composeTopicName in class VeniceView

getWriterClassName

public String getWriterClassName()

Description copied from class: VeniceView

Implementations should return the fully specified class name for the component VeniceViewWriter implementation.

Overrides:

getWriterClassName in class VeniceView

Returns:

returns the className of the writer which should be instantiated.

validateConfigs

public void validateConfigs(Store store)

Description copied from class: VeniceView

Validate that the configs set up for this view for this store are valid. If not, throw an exception. Implementors should override this function to add their own validation logic.

Overrides:

validateConfigs in class VeniceView