Package com.linkedin.venice.views

Class MaterializedView

java.lang.Object

com.linkedin.venice.views.VeniceView

com.linkedin.venice.views.MaterializedView

public class MaterializedView
extends VeniceView

Field Summary

Fields

Modifier and Type	Field	Description
static final String	MATERIALIZED_VIEW_TOPIC_SUFFIX
static final String	MATERIALIZED_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
MaterializedView(Properties props, String storeName, Map<String,String> viewParameters)

Method Summary

Modifier and Type	Method	Description
String	composeTopicName(int version)
PartitionerConfig	getPartitionerConfig()
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	getViewName()
int	getViewPartitionCount()
VenicePartitioner	getViewPartitioner()
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)	MaterializedViewParameters.MATERIALIZED_VIEW_PARTITION_COUNT is required to configure a new re-partition view.

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

MATERIALIZED_VIEW_TOPIC_SUFFIX

public static final String MATERIALIZED_VIEW_TOPIC_SUFFIX

See Also:

• Constant Field Values

MATERIALIZED_VIEW_WRITER_CLASS_NAME

public static final String MATERIALIZED_VIEW_WRITER_CLASS_NAME

See Also:

• Constant Field Values

Constructor Details

MaterializedView

public MaterializedView(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

validateConfigs

public void validateConfigs(Store store)

MaterializedViewParameters.MATERIALIZED_VIEW_PARTITION_COUNT is required to configure a new re-partition view. MaterializedViewParameters.MATERIALIZED_VIEW_PARTITIONER is optional. The re-partition view will use the store level partitioner config if it's not specified in the view parameters. MaterializedViewParameters.MATERIALIZED_VIEW_PARTITIONER_PARAMS is optional.

Overrides:

validateConfigs 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.

getViewPartitionCount

public int getViewPartitionCount()

getViewPartitioner

public VenicePartitioner getViewPartitioner()

getViewName

public String getViewName()

getPartitionerConfig

public PartitionerConfig getPartitionerConfig()