Package com.linkedin.venice.meta

Class ReadOnlyStore.ReadOnlyVersion

java.lang.Object

com.linkedin.venice.meta.ReadOnlyStore.ReadOnlyVersion

All Implemented Interfaces:

DataModelBackedStructure<StoreVersion>, Version, Comparable<Version>

Direct Known Subclasses:

ReadOnlyViewStore.ReadOnlyMaterializedViewVersion

Enclosing class:

ReadOnlyStore

public static class ReadOnlyStore.ReadOnlyVersion
extends Object
implements Version

A read-only wrapper of Version

Nested Class Summary

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

Version.PushType

Field Summary

Fields

Modifier and Type	Field	Description
protected final Version	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
ReadOnlyVersion(Version delegate)

Method Summary

Modifier and Type	Method	Description
Version	cloneVersion()
int	compareTo(Version o)
StoreVersion	dataModel()	Return the backed data model.
boolean	equals(Object o)
Duration	getAge()
String	getBlobTransferInServerEnabled()
CompressionStrategy	getCompressionStrategy()
long	getCreatedTime()
DataRecoveryVersionConfig	getDataRecoveryVersionConfig()
HybridStoreConfig	getHybridStoreConfig()
boolean	getIsDavinciHeartbeatReported()
List<String>	getKeyUrnFields()
int	getMinActiveReplicas()
String	getNativeReplicationSourceFabric()
int	getNumber()
int	getPartitionCount()
PartitionerConfig	getPartitionerConfig()
String	getPushJobId()
String	getPushStreamSourceAddress()
Version.PushType	getPushType()
int	getReplicationFactor()
int	getRepushSourceVersion()
int	getRmdVersionId()
VersionStatus	getStatus()
String	getStoreName()
String	getTargetSwapRegion()
int	getTargetSwapRegionWaitTime()
Map<String,ViewConfig>	getViewConfigs()
int	hashCode()
boolean	isActiveActiveReplicationEnabled()
boolean	isBlobTransferEnabled()
boolean	isChunkingEnabled()
boolean	isGlobalRtDivEnabled()
boolean	isHybrid()
boolean	isIncrementalPushEnabled()
boolean	isKeyUrnCompressionEnabled()
boolean	isNativeReplicationEnabled()
boolean	isRmdChunkingEnabled()
boolean	isSeparateRealTimeTopicEnabled()
boolean	isUseVersionLevelHybridConfig()
boolean	isUseVersionLevelIncrementalPushEnabled()
boolean	isVersionSwapDeferred()
String	kafkaTopicName()	Kafka topic name is composed by store name and version.
void	setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled)
void	setAge(Duration age)
void	setBlobTransferEnabled(boolean blobTransferEnabled)
void	setBlobTransferInServerEnabled(String blobTransferInServerEnabled)
void	setBufferReplayEnabledForHybrid(boolean bufferReplayEnabledForHybrid)
void	setChunkingEnabled(boolean chunkingEnabled)
void	setCompressionStrategy(CompressionStrategy compressionStrategy)
void	setDataRecoveryVersionConfig(DataRecoveryVersionConfig dataRecoveryVersionConfig)
void	setGlobalRtDivEnabled(boolean globalRtDivEnabled)
void	setHybridStoreConfig(HybridStoreConfig hybridConfig)
void	setIncrementalPushEnabled(boolean incrementalPushEnabled)
void	setIsDavinciHeartbeatReported(boolean isReported)
void	setKeyUrnCompressionEnabled(boolean keyUrnCompressionEnabled)
void	setKeyUrnFields(List<String> keyUrnFields)
void	setNativeReplicationEnabled(boolean nativeReplicationEnabled)
void	setNativeReplicationSourceFabric(String nativeReplicationSourceFabric)
void	setNumber(int number)
void	setPartitionCount(int partitionCount)
void	setPartitionerConfig(PartitionerConfig partitionerConfig)
void	setPushJobId(String pushJobId)
void	setPushStreamSourceAddress(String address)
void	setPushType(Version.PushType pushType)
void	setReplicationFactor(int replicationFactor)
void	setRepushSourceVersion(int version)
void	setRmdChunkingEnabled(boolean rmdChunkingEnabled)
void	setRmdVersionId(int replicationMetadataVersionId)
void	setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled)
void	setStatus(VersionStatus status)
void	setTargetSwapRegion(String targetRegion)
void	setTargetSwapRegionWaitTime(int waitTime)
void	setUseVersionLevelHybridConfig(boolean versionLevelHybridConfig)
void	setUseVersionLevelIncrementalPushEnabled(boolean versionLevelIncrementalPushEnabled)
void	setVersionSwapDeferred(boolean versionSwapDeferred)
void	setViewConfigs(Map<String,ViewConfig> viewConfigList)
String	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

Field Details

delegate

protected final Version delegate

Constructor Details

ReadOnlyVersion

public ReadOnlyVersion(Version delegate)

Method Details

getNumber

public int getNumber()

Specified by:

getNumber in interface Version

setNumber

public void setNumber(int number)

Specified by:

setNumber in interface Version

getCreatedTime

public long getCreatedTime()

Specified by:

getCreatedTime in interface Version

getAge

public Duration getAge()

Specified by:

getAge in interface Version

setAge

public void setAge(Duration age)

Specified by:

setAge in interface Version

getStatus

public VersionStatus getStatus()

Specified by:

getStatus in interface Version

setStatus

public void setStatus(VersionStatus status)

Specified by:

setStatus in interface Version

getCompressionStrategy

public CompressionStrategy getCompressionStrategy()

Specified by:

getCompressionStrategy in interface Version

setCompressionStrategy

public void setCompressionStrategy(CompressionStrategy compressionStrategy)

Specified by:

setCompressionStrategy in interface Version

isNativeReplicationEnabled

public boolean isNativeReplicationEnabled()

Specified by:

isNativeReplicationEnabled in interface Version

setNativeReplicationEnabled

public void setNativeReplicationEnabled(boolean nativeReplicationEnabled)

Specified by:

setNativeReplicationEnabled in interface Version

getPushStreamSourceAddress

public String getPushStreamSourceAddress()

Specified by:

getPushStreamSourceAddress in interface Version

setPushStreamSourceAddress

public void setPushStreamSourceAddress(String address)

Specified by:

setPushStreamSourceAddress in interface Version

setBufferReplayEnabledForHybrid

public void setBufferReplayEnabledForHybrid(boolean bufferReplayEnabledForHybrid)

Specified by:

setBufferReplayEnabledForHybrid in interface Version

isChunkingEnabled

public boolean isChunkingEnabled()

Specified by:

isChunkingEnabled in interface Version

setChunkingEnabled

public void setChunkingEnabled(boolean chunkingEnabled)

Specified by:

setChunkingEnabled in interface Version

isRmdChunkingEnabled

public boolean isRmdChunkingEnabled()

Specified by:

isRmdChunkingEnabled in interface Version

setRmdChunkingEnabled

public void setRmdChunkingEnabled(boolean rmdChunkingEnabled)

Specified by:

setRmdChunkingEnabled in interface Version

getStoreName

public String getStoreName()

Specified by:

getStoreName in interface Version

getPushJobId

public String getPushJobId()

Specified by:

getPushJobId in interface Version

setPushJobId

public void setPushJobId(String pushJobId)

Specified by:

setPushJobId in interface Version

getPushType

public Version.PushType getPushType()

Specified by:

getPushType in interface Version

setPushType

public void setPushType(Version.PushType pushType)

Specified by:

setPushType in interface Version

setPartitionCount

public void setPartitionCount(int partitionCount)

Specified by:

setPartitionCount in interface Version

getPartitionCount

public int getPartitionCount()

Specified by:

getPartitionCount in interface Version

getPartitionerConfig

public PartitionerConfig getPartitionerConfig()

Specified by:

getPartitionerConfig in interface Version

setPartitionerConfig

public void setPartitionerConfig(PartitionerConfig partitionerConfig)

Specified by:

setPartitionerConfig in interface Version

isVersionSwapDeferred

public boolean isVersionSwapDeferred()

Specified by:

isVersionSwapDeferred in interface Version

setVersionSwapDeferred

public void setVersionSwapDeferred(boolean versionSwapDeferred)

Specified by:

setVersionSwapDeferred in interface Version

getReplicationFactor

public int getReplicationFactor()

Specified by:

getReplicationFactor in interface Version

setReplicationFactor

public void setReplicationFactor(int replicationFactor)

Specified by:

setReplicationFactor in interface Version

getMinActiveReplicas

public int getMinActiveReplicas()

Specified by:

getMinActiveReplicas in interface Version

getNativeReplicationSourceFabric

public String getNativeReplicationSourceFabric()

Specified by:

getNativeReplicationSourceFabric in interface Version

setNativeReplicationSourceFabric

public void setNativeReplicationSourceFabric(String nativeReplicationSourceFabric)

Specified by:

setNativeReplicationSourceFabric in interface Version

isIncrementalPushEnabled

public boolean isIncrementalPushEnabled()

Specified by:

isIncrementalPushEnabled in interface Version

setIncrementalPushEnabled

public void setIncrementalPushEnabled(boolean incrementalPushEnabled)

Specified by:

setIncrementalPushEnabled in interface Version

isSeparateRealTimeTopicEnabled

public boolean isSeparateRealTimeTopicEnabled()

Specified by:

isSeparateRealTimeTopicEnabled in interface Version

setSeparateRealTimeTopicEnabled

public void setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled)

Specified by:

setSeparateRealTimeTopicEnabled in interface Version

isBlobTransferEnabled

public boolean isBlobTransferEnabled()

Specified by:

isBlobTransferEnabled in interface Version

setBlobTransferEnabled

public void setBlobTransferEnabled(boolean blobTransferEnabled)

Specified by:

setBlobTransferEnabled in interface Version

getBlobTransferInServerEnabled

public String getBlobTransferInServerEnabled()

Specified by:

getBlobTransferInServerEnabled in interface Version

setBlobTransferInServerEnabled

public void setBlobTransferInServerEnabled(String blobTransferInServerEnabled)

Specified by:

setBlobTransferInServerEnabled in interface Version

isUseVersionLevelIncrementalPushEnabled

public boolean isUseVersionLevelIncrementalPushEnabled()

Specified by:

isUseVersionLevelIncrementalPushEnabled in interface Version

setUseVersionLevelIncrementalPushEnabled

public void setUseVersionLevelIncrementalPushEnabled(boolean versionLevelIncrementalPushEnabled)

Specified by:

setUseVersionLevelIncrementalPushEnabled in interface Version

isHybrid

public boolean isHybrid()

Specified by:

isHybrid in interface Version

getHybridStoreConfig

public HybridStoreConfig getHybridStoreConfig()

Specified by:

getHybridStoreConfig in interface Version

setHybridStoreConfig

public void setHybridStoreConfig(HybridStoreConfig hybridConfig)

Specified by:

setHybridStoreConfig in interface Version

getViewConfigs

public Map<String,ViewConfig> getViewConfigs()

Specified by:

getViewConfigs in interface Version

setViewConfigs

public void setViewConfigs(Map<String,ViewConfig> viewConfigList)

Specified by:

setViewConfigs in interface Version

isUseVersionLevelHybridConfig

public boolean isUseVersionLevelHybridConfig()

Specified by:

isUseVersionLevelHybridConfig in interface Version

setUseVersionLevelHybridConfig

public void setUseVersionLevelHybridConfig(boolean versionLevelHybridConfig)

Specified by:

setUseVersionLevelHybridConfig in interface Version

isActiveActiveReplicationEnabled

public boolean isActiveActiveReplicationEnabled()

Specified by:

isActiveActiveReplicationEnabled in interface Version

setActiveActiveReplicationEnabled

public void setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled)

Specified by:

setActiveActiveReplicationEnabled in interface Version

getDataRecoveryVersionConfig

public DataRecoveryVersionConfig getDataRecoveryVersionConfig()

Specified by:

getDataRecoveryVersionConfig in interface Version

setDataRecoveryVersionConfig

public void setDataRecoveryVersionConfig(DataRecoveryVersionConfig dataRecoveryVersionConfig)

Specified by:

setDataRecoveryVersionConfig in interface Version

getTargetSwapRegion

public String getTargetSwapRegion()

Specified by:

getTargetSwapRegion in interface Version

getTargetSwapRegionWaitTime

public int getTargetSwapRegionWaitTime()

Specified by:

getTargetSwapRegionWaitTime in interface Version

setTargetSwapRegion

public void setTargetSwapRegion(String targetRegion)

Specified by:

setTargetSwapRegion in interface Version

setTargetSwapRegionWaitTime

public void setTargetSwapRegionWaitTime(int waitTime)

Specified by:

setTargetSwapRegionWaitTime in interface Version

setIsDavinciHeartbeatReported

public void setIsDavinciHeartbeatReported(boolean isReported)

Specified by:

setIsDavinciHeartbeatReported in interface Version

getIsDavinciHeartbeatReported

public boolean getIsDavinciHeartbeatReported()

Specified by:

getIsDavinciHeartbeatReported in interface Version

isGlobalRtDivEnabled

public boolean isGlobalRtDivEnabled()

Specified by:

isGlobalRtDivEnabled in interface Version

setGlobalRtDivEnabled

public void setGlobalRtDivEnabled(boolean globalRtDivEnabled)

Specified by:

setGlobalRtDivEnabled in interface Version

setKeyUrnCompressionEnabled

public void setKeyUrnCompressionEnabled(boolean keyUrnCompressionEnabled)

Specified by:

setKeyUrnCompressionEnabled in interface Version

isKeyUrnCompressionEnabled

public boolean isKeyUrnCompressionEnabled()

Specified by:

isKeyUrnCompressionEnabled in interface Version

setKeyUrnFields

public void setKeyUrnFields(List<String> keyUrnFields)

Specified by:

setKeyUrnFields in interface Version

getKeyUrnFields

public List<String> getKeyUrnFields()

Specified by:

getKeyUrnFields in interface Version

setRepushSourceVersion

public void setRepushSourceVersion(int version)

Specified by:

setRepushSourceVersion in interface Version

getRepushSourceVersion

public int getRepushSourceVersion()

Specified by:

getRepushSourceVersion in interface Version

getRmdVersionId

public int getRmdVersionId()

Specified by:

getRmdVersionId in interface Version

setRmdVersionId

public void setRmdVersionId(int replicationMetadataVersionId)

Specified by:

setRmdVersionId in interface Version

cloneVersion

public Version cloneVersion()

Specified by:

cloneVersion in interface Version

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

Returns:

kafka topic name.

dataModel

public StoreVersion dataModel()

Description copied from interface: DataModelBackedStructure

Return the backed data model.

Specified by:

dataModel in interface DataModelBackedStructure<StoreVersion>

Returns:

compareTo

public int compareTo(Version o)

Specified by:

compareTo in interface Comparable<Version>

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object