Package com.linkedin.venice.meta

Class VersionImpl

java.lang.Object

com.linkedin.venice.meta.VersionImpl

All Implemented Interfaces:

DataModelBackedStructure<StoreVersion>, Version, Comparable<Version>

public class VersionImpl
extends Object
implements Version

Class defines the version of Venice store.

Nested Class Summary

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

Version.PushType

Field Summary

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

REAL_TIME_TOPIC_SUFFIX, REPLICATION_METADATA_VERSION_ID_UNSET, SEPARATE_REAL_TIME_TOPIC_SUFFIX, STREAM_REPROCESSING_TOPIC_SUFFIX, VENICE_RE_PUSH_PUSH_ID_PREFIX, VENICE_TTL_RE_PUSH_PUSH_ID_PREFIX, VERSION_SEPARATOR

Constructor Summary

Constructors

Constructor	Description
VersionImpl(String storeName, int number)	Deprecated.
VersionImpl(String storeName, int number, long createdTime, String pushJobId, int partitionCount, PartitionerConfig partitionerConfig, DataRecoveryVersionConfig dataRecoveryVersionConfig)
VersionImpl(String storeName, int number, String pushJobId)
VersionImpl(String storeName, int number, String pushJobId, int partitionCount)

Method Summary

Modifier and Type	Method	Description
Version	cloneVersion()	Clone a new version based on current data in this version.
int	compareTo(Version o)
StoreVersion	dataModel()	Return the backed data model.
boolean	equals(Object o)
Duration	getAge()
CompressionStrategy	getCompressionStrategy()
long	getCreatedTime()
DataRecoveryVersionConfig	getDataRecoveryVersionConfig()
HybridStoreConfig	getHybridStoreConfig()
boolean	getIsDavinciHeartbeatReported()
int	getMinActiveReplicas()
String	getNativeReplicationSourceFabric()
final int	getNumber()
int	getPartitionCount()
PartitionerConfig	getPartitionerConfig()
String	getPushJobId()
String	getPushStreamSourceAddress()
Version.PushType	getPushType()
int	getReplicationFactor()
int	getRepushSourceVersion()
int	getRmdVersionId()
VersionStatus	getStatus()
final String	getStoreName()
String	getTargetSwapRegion()
int	getTargetSwapRegionWaitTime()
Map<String,ViewConfig>	getViewConfigs()
int	hashCode()
boolean	isActiveActiveReplicationEnabled()
boolean	isBlobTransferEnabled()
boolean	isChunkingEnabled()
boolean	isHybrid()
boolean	isIncrementalPushEnabled()
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	setBufferReplayEnabledForHybrid(boolean bufferReplayEnabledForHybrid)
void	setChunkingEnabled(boolean chunkingEnabled)
void	setCompressionStrategy(CompressionStrategy compressionStrategy)
void	setDataRecoveryVersionConfig(DataRecoveryVersionConfig dataRecoveryVersionConfig)
void	setHybridStoreConfig(HybridStoreConfig hybridConfig)
void	setIncrementalPushEnabled(boolean incrementalPushEnabled)
void	setIsDavinciHeartbeatReported(boolean isReported)
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 deferVersionSwap)
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

Constructor Details

VersionImpl

@Deprecated
public VersionImpl(String storeName,
 int number)

Deprecated.

Use the constructor that specifies a pushJobId instead Currently used in tests only.

VersionImpl

public VersionImpl(String storeName,
 int number,
 String pushJobId)

VersionImpl

public VersionImpl(String storeName,
 int number,
 String pushJobId,
 int partitionCount)

VersionImpl

public VersionImpl(String storeName,
 int number,
 long createdTime,
 String pushJobId,
 int partitionCount,
 PartitionerConfig partitionerConfig,
 DataRecoveryVersionConfig dataRecoveryVersionConfig)

Method Details

getNumber

public final 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 final 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 deferVersionSwap)

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

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

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

setTargetSwapRegion

public void setTargetSwapRegion(String targetRegion)

Specified by:

setTargetSwapRegion in interface Version

getTargetSwapRegion

public String getTargetSwapRegion()

Specified by:

getTargetSwapRegion in interface Version

setTargetSwapRegionWaitTime

public void setTargetSwapRegionWaitTime(int waitTime)

Specified by:

setTargetSwapRegionWaitTime in interface Version

getTargetSwapRegionWaitTime

public int getTargetSwapRegionWaitTime()

Specified by:

getTargetSwapRegionWaitTime 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

dataModel

public StoreVersion dataModel()

Description copied from interface: DataModelBackedStructure

Return the backed data model.

Specified by:

dataModel in interface DataModelBackedStructure<StoreVersion>

Returns:

toString

public String toString()

Overrides:

toString in class Object

compareTo

public int compareTo(Version o)

Specified by:

compareTo in interface Comparable<Version>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

cloneVersion

public Version cloneVersion()

Clone a new version based on current data in this version.

Specified by:

cloneVersion in interface Version

Returns:

cloned version.

kafkaTopicName

public String kafkaTopicName()

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

Specified by:

kafkaTopicName in interface Version

Returns:

kafka topic name.