Package com.linkedin.venice.meta

Class ReadOnlyViewStore.ReadOnlyMaterializedViewVersion

java.lang.Object

com.linkedin.venice.meta.ReadOnlyStore.ReadOnlyVersion

com.linkedin.venice.meta.ReadOnlyViewStore.ReadOnlyMaterializedViewVersion

All Implemented Interfaces:

DataModelBackedStructure<StoreVersion>, Version, Comparable<Version>

Enclosing class:

ReadOnlyViewStore

public static class ReadOnlyViewStore.ReadOnlyMaterializedViewVersion
extends ReadOnlyStore.ReadOnlyVersion

A read only Version representation of a materialized view for consumers (e.g. DVC client). Any view specific version properties will be overwritten here and provided by the corresponding MaterializedView.

Nested Class Summary

Nested classes/interfaces inherited from interface com.linkedin.venice.meta.Version

Version.PushType

Field Summary

Fields inherited from class com.linkedin.venice.meta.ReadOnlyStore.ReadOnlyVersion

delegate

Fields inherited from interface com.linkedin.venice.meta.Version

DEFAULT_RT_VERSION_NUMBER, REAL_TIME_TOPIC_SUFFIX, REAL_TIME_TOPIC_TEMPLATE, REPLICATION_METADATA_VERSION_ID_UNSET, STREAM_REPROCESSING_TOPIC_SUFFIX, VENICE_RE_PUSH_PUSH_ID_PREFIX, VENICE_REGULAR_PUSH_WITH_TTL_RE_PUSH_PREFIX, VENICE_TTL_RE_PUSH_PUSH_ID_PREFIX, VERSION_SEPARATOR

Constructor Summary

Constructors

Constructor	Description
ReadOnlyMaterializedViewVersion(Version delegate, ViewConfig viewConfig)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	getPartitionCount()
PartitionerConfig	getPartitionerConfig()
String	getStoreName()
int	hashCode()
String	kafkaTopicName()	Kafka topic name is composed by store name and version.

Methods inherited from class com.linkedin.venice.meta.ReadOnlyStore.ReadOnlyVersion

cloneVersion, compareTo, dataModel, getAge, getBlobTransferInServerEnabled, getCompressionStrategy, getCreatedTime, getDataRecoveryVersionConfig, getHybridStoreConfig, getIsDavinciHeartbeatReported, getKeyUrnFields, getMinActiveReplicas, getNativeReplicationSourceFabric, getNumber, getPushJobId, getPushStreamSourceAddress, getPushType, getReplicationFactor, getRepushSourceVersion, getRmdVersionId, getStatus, getTargetSwapRegion, getTargetSwapRegionWaitTime, getViewConfigs, isActiveActiveReplicationEnabled, isBlobTransferEnabled, isChunkingEnabled, isGlobalRtDivEnabled, isHybrid, isIncrementalPushEnabled, isKeyUrnCompressionEnabled, isNativeReplicationEnabled, isRmdChunkingEnabled, isSeparateRealTimeTopicEnabled, isUseVersionLevelHybridConfig, isUseVersionLevelIncrementalPushEnabled, isVersionSwapDeferred, setActiveActiveReplicationEnabled, setAge, setBlobTransferEnabled, setBlobTransferInServerEnabled, setBufferReplayEnabledForHybrid, setChunkingEnabled, setCompressionStrategy, setDataRecoveryVersionConfig, setGlobalRtDivEnabled, setHybridStoreConfig, setIncrementalPushEnabled, setIsDavinciHeartbeatReported, setKeyUrnCompressionEnabled, setKeyUrnFields, setNativeReplicationEnabled, setNativeReplicationSourceFabric, setNumber, setPartitionCount, setPartitionerConfig, setPushJobId, setPushStreamSourceAddress, setPushType, setReplicationFactor, setRepushSourceVersion, setRmdChunkingEnabled, setRmdVersionId, setSeparateRealTimeTopicEnabled, setStatus, setTargetSwapRegion, setTargetSwapRegionWaitTime, setUseVersionLevelHybridConfig, setUseVersionLevelIncrementalPushEnabled, setVersionSwapDeferred, setViewConfigs, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.linkedin.venice.meta.Version

getTimestampMetadataVersionId, isLeaderFollowerModelEnabled, setLeaderFollowerModelEnabled, setTimestampMetadataVersionId

Constructor Details

ReadOnlyMaterializedViewVersion

public ReadOnlyMaterializedViewVersion(Version delegate,
 ViewConfig viewConfig)

Method Details

getPartitionCount

public int getPartitionCount()

Specified by:

getPartitionCount in interface Version

Overrides:

getPartitionCount in class ReadOnlyStore.ReadOnlyVersion

kafkaTopicName

public String kafkaTopicName()

Description copied from interface: Version

Kafka topic name is composed by store name and version.

The Json deserializer will think it should be a field called kafkaTopicName if we use "getKafkaTopicName" here. So use "kafkaTopicName" directly here to avoid error when deserialize.

Specified by:

kafkaTopicName in interface Version

Overrides:

kafkaTopicName in class ReadOnlyStore.ReadOnlyVersion

Returns:

kafka topic name.

getPartitionerConfig

public PartitionerConfig getPartitionerConfig()

Specified by:

getPartitionerConfig in interface Version

Overrides:

getPartitionerConfig in class ReadOnlyStore.ReadOnlyVersion

equals

public boolean equals(Object o)

Overrides:

equals in class ReadOnlyStore.ReadOnlyVersion

hashCode

public int hashCode()

Overrides:

hashCode in class ReadOnlyStore.ReadOnlyVersion

getStoreName

public String getStoreName()

Specified by:

getStoreName in interface Version

Overrides:

getStoreName in class ReadOnlyStore.ReadOnlyVersion