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 java.lang.String	CHANGE_CAPTURE_TOPIC_SUFFIX
static java.lang.String	CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME

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

props, store, VIEW_TOPIC_SEPARATOR, viewParameters

Constructor Summary

Constructors

Constructor	Description
ChangeCaptureView(java.util.Properties props, Store store, java.util.Map<java.lang.String,java.lang.String> viewParameters)

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.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.
java.lang.String	getWriterClassName()	Implementations should return the fully specified class name for the component VeniceViewWriter implementation.
void	validateConfigs()	Validate that the configs set up for this view for this store are valid.

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

close, isViewTopic, parseStoreFromViewTopic, parseVersionFromViewTopic

Methods inherited from class java.lang.Object

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

Field Detail

CHANGE_CAPTURE_TOPIC_SUFFIX

public static final java.lang.String CHANGE_CAPTURE_TOPIC_SUFFIX

See Also:

Constant Field Values

CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME

public static final java.lang.String CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME

See Also:

Constant Field Values

Constructor Detail

ChangeCaptureView

public ChangeCaptureView(java.util.Properties props,
                         Store store,
                         java.util.Map<java.lang.String,java.lang.String> viewParameters)

Method Detail

getTopicNamesAndConfigsForVersion

public java.util.Map<java.lang.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

getWriterClassName

public java.lang.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()

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, and need only call this base implementation optionally.

Overrides:

validateConfigs in class VeniceView