Package com.linkedin.venice.meta

Class ReadOnlyStore

java.lang.Object

com.linkedin.venice.meta.ReadOnlyStore

All Implemented Interfaces:

Store

Direct Known Subclasses:

ReadOnlyViewStore

public class ReadOnlyStore
extends Object
implements Store

A read-only wrapper of Store, and all the modification to delegated instance will throw UnsupportedOperationException.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReadOnlyStore.ReadOnlyVersion	A read-only wrapper of Version

Field Summary

Fields

Modifier and Type	Field	Description
protected final Store	delegate

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

BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOURS, DEFAULT_BATCH_GET_LIMIT, DEFAULT_RT_RETENTION_TIME, IGNORE_VERSION, NON_EXISTING_VERSION, NUM_VERSION_PRESERVE_NOT_SET, SYSTEM_STORE_FORMAT, SYSTEM_STORE_NAME_PREFIX, UNLIMITED_STORAGE_QUOTA

Constructor Summary

Constructors

Constructor	Description
ReadOnlyStore(Store delegate)

Method Summary

Modifier and Type	Method	Description
void	addVersion(Version version)
void	addVersion(Version version, boolean isClonedVersion, int currentRTVersionNumber)
void	checkDisableStoreWrite(String action, int version)
Store	cloneStore()
StoreProperties	cloneStoreProperties()
boolean	containsVersion(int versionNumber)
Version	deleteVersion(int versionNumber)
boolean	equals(Object o)
void	fixMissingFields()
void	forceAddVersion(Version version, boolean isClonedVersion)
BackupStrategy	getBackupStrategy()
long	getBackupVersionRetentionMs()
int	getBatchGetLimit()
String	getBlobTransferInServerEnabled()
int	getBootstrapToOnlineTimeoutInHours()
boolean	getClientDecompressionEnabled()
long	getCompactionThresholdMilliseconds()
CompressionStrategy	getCompressionStrategy()
long	getCreatedTime()
int	getCurrentVersion()
ETLStoreConfig	getEtlStoreConfig()
HybridStoreConfig	getHybridStoreConfig()
boolean	getIsDavinciHeartbeatReported()
List<String>	getKeyUrnFields()
int	getLargestUsedRTVersionNumber()
int	getLargestUsedVersionNumber()
int	getLatestSuperSetValueSchemaId()
long	getLatestVersionPromoteToCurrentTimestamp()
long	getLowWatermark()
long	getMaxCompactionLagSeconds()
int	getMaxNearlineRecordSizeBytes()
int	getMaxRecordSizeBytes()
long	getMinCompactionLagSeconds()
String	getName()
String	getNativeReplicationSourceFabric()
int	getNearlineProducerCountPerWriter()
int	getNumVersionsToPreserve()
OfflinePushStrategy	getOffLinePushStrategy()
String	getOwner()
int	getPartitionCount()
PartitionerConfig	getPartitionerConfig()
PersistenceType	getPersistenceType()
String	getPushStreamSourceAddress()
long	getReadQuotaInCU()
ReadStrategy	getReadStrategy()
int	getReplicationFactor()
long	getRetentionTime()
int	getRmdVersion()
RoutingStrategy	getRoutingStrategy()
long	getStorageQuotaInByte()
List<LifecycleHooksRecord>	getStoreLifecycleHooks()
Map<String,SystemStoreAttributes>	getSystemStores()
String	getTargetSwapRegion()
int	getTargetSwapRegionWaitTime()
Version	getVersion(int versionNumber)
Version	getVersionOrThrow(int versionNumber)
List<Version>	getVersions()
VersionStatus	getVersionStatus(int versionNumber)
Map<String,ViewConfig>	getViewConfigs()
int	hashCode()
boolean	isAccessControlled()
boolean	isActiveActiveReplicationEnabled()
boolean	isBlobTransferEnabled()
boolean	isChunkingEnabled()
boolean	isCompactionEnabled()
boolean	isDaVinciPushStatusStoreEnabled()
boolean	isEnableReads()
boolean	isEnableWrites()
boolean	isEnumSchemaEvolutionAllowed()
boolean	isGlobalRtDivEnabled()
boolean	isHybrid()
boolean	isHybridStoreDiskQuotaEnabled()
boolean	isIncrementalPushEnabled()
boolean	isKeyUrnCompressionEnabled()
boolean	isMigrating()
boolean	isMigrationDuplicateStore()
boolean	isNativeReplicationEnabled()
boolean	isNearlineProducerCompressionEnabled()
boolean	isReadComputationEnabled()
boolean	isRmdChunkingEnabled()
boolean	isSchemaAutoRegisterFromPushJobEnabled()
boolean	isSeparateRealTimeTopicEnabled()
boolean	isStorageNodeReadQuotaEnabled()
boolean	isStoreMetadataSystemStoreEnabled()
boolean	isStoreMetaSystemStoreEnabled()
boolean	isSystemStore()
boolean	isTTLRepushEnabled()
boolean	isUnusedSchemaDeletionEnabled()
boolean	isWriteComputationEnabled()
int	peekNextVersionNumber()
void	putSystemStore(VeniceSystemStoreType systemStoreType, SystemStoreAttributes systemStoreAttributes)
List<Version>	retrieveVersionsToDelete(int clusterNumVersionsToPreserve)
void	setAccessControlled(boolean accessControlled)
void	setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled)
void	setBackupStrategy(BackupStrategy value)
void	setBackupVersionRetentionMs(long backupVersionRetentionMs)
void	setBatchGetLimit(int batchGetLimit)
void	setBlobTransferEnabled(boolean blobTransferEnabled)
void	setBlobTransferInServerEnabled(String blobTransferInServerEnabled)
void	setBootstrapToOnlineTimeoutInHours(int bootstrapToOnlineTimeoutInHours)
void	setChunkingEnabled(boolean chunkingEnabled)
void	setClientDecompressionEnabled(boolean clientDecompressionEnabled)
void	setCompactionEnabled(boolean compactionEnabled)
void	setCompactionThresholdMilliseconds(long compactionThreshold)
void	setCompressionStrategy(CompressionStrategy compressionStrategy)
void	setCurrentVersion(int currentVersion)
void	setCurrentVersionWithoutCheck(int currentVersion)
void	setDaVinciPushStatusStoreEnabled(boolean daVinciPushStatusStoreEnabled)
void	setEnableReads(boolean enableReads)
void	setEnableWrites(boolean enableWrites)
void	setEnumSchemaEvolutionAllowed(boolean enumSchemaEvolutionAllowed)
void	setEtlStoreConfig(ETLStoreConfig etlStoreConfig)
void	setGlobalRtDivEnabled(boolean globalRtDivEnabled)
void	setHybridStoreConfig(HybridStoreConfig hybridStoreConfig)
void	setHybridStoreDiskQuotaEnabled(boolean enabled)
void	setIncrementalPushEnabled(boolean incrementalPushEnabled)
void	setIsDavinciHeartbeatReported(boolean isReported)
void	setKeyUrnCompressionEnabled(boolean keyUrnCompressionEnabled)
void	setKeyUrnFields(List<String> keyUrnFieldList)
void	setLargestUsedRTVersionNumber(int largestUsedRTVersionNumber)
void	setLargestUsedVersionNumber(int largestUsedVersionNumber)
void	setLatestSuperSetValueSchemaId(int valueSchemaId)
void	setLatestVersionPromoteToCurrentTimestamp(long latestVersionPromoteToCurrentTimestamp)
void	setLowWatermark(long lowWatermark)
void	setMaxCompactionLagSeconds(long maxCompactionLagSeconds)
void	setMaxNearlineRecordSizeBytes(int maxNearlineRecordSizeBytes)
void	setMaxRecordSizeBytes(int maxRecordSizeBytes)
void	setMigrating(boolean migrating)
void	setMigrationDuplicateStore(boolean migrationDuplicateStore)
void	setMinCompactionLagSeconds(long minCompactionLagSeconds)
void	setNativeReplicationEnabled(boolean nativeReplicationEnabled)
void	setNativeReplicationSourceFabric(String nativeReplicationSourceFabric)
void	setNearlineProducerCompressionEnabled(boolean compressionEnabled)
void	setNearlineProducerCountPerWriter(int producerCnt)
void	setNumVersionsToPreserve(int numVersionsToPreserve)
void	setOwner(String owner)
void	setPartitionCount(int partitionCount)
void	setPartitionerConfig(PartitionerConfig value)
void	setPersistenceType(PersistenceType persistenceType)
void	setPushStreamSourceAddress(String sourceAddress)
void	setReadComputationEnabled(boolean readComputationEnabled)
void	setReadQuotaInCU(long readQuotaInCU)
void	setReplicationFactor(int replicationFactor)
void	setRmdChunkingEnabled(boolean rmdChunkingEnabled)
void	setRmdVersion(int rmdVersion)
void	setSchemaAutoRegisterFromPushJobEnabled(boolean value)
void	setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled)
void	setStorageNodeReadQuotaEnabled(boolean storageNodeReadQuotaEnabled)
void	setStorageQuotaInByte(long storageQuotaInByte)
void	setStoreLifecycleHooks(List<LifecycleHooksRecord> storeLifecycleHooks)
void	setStoreMetadataSystemStoreEnabled(boolean storeMetadataSystemStoreEnabled)
void	setStoreMetaSystemStoreEnabled(boolean storeMetaSystemStoreEnabled)
void	setSystemStores(Map<String,SystemStoreAttributes> systemStores)
void	setTargetSwapRegion(String targetRegion)
void	setTargetSwapRegionWaitTime(int waitTime)
void	setTTLRepushEnabled(boolean ttlRepushEnabled)
void	setUnusedSchemaDeletionEnabled(boolean unusedSchemaDeletionEnabled)
void	setVersions(List<Version> versions)
void	setViewConfigs(Map<String,ViewConfig> viewConfigList)
void	setWriteComputationEnabled(boolean writeComputationEnabled)
String	toString()
void	updateVersionForDaVinciHeartbeat(int versionNumber, boolean reported)
void	updateVersionStatus(int versionNumber, VersionStatus status)

Methods inherited from class java.lang.Object

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

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

getVersionNumbers

Field Details

delegate

protected final Store delegate

Constructor Details

ReadOnlyStore

public ReadOnlyStore(Store delegate)

Method Details

getName

public String getName()

Specified by:

getName in interface Store

getOwner

public String getOwner()

Specified by:

getOwner in interface Store

setOwner

public void setOwner(String owner)

Specified by:

setOwner in interface Store

getCreatedTime

public long getCreatedTime()

Specified by:

getCreatedTime in interface Store

getCurrentVersion

public int getCurrentVersion()

Specified by:

getCurrentVersion in interface Store

setCurrentVersion

public void setCurrentVersion(int currentVersion)

Specified by:

setCurrentVersion in interface Store

setCurrentVersionWithoutCheck

public void setCurrentVersionWithoutCheck(int currentVersion)

Specified by:

setCurrentVersionWithoutCheck in interface Store

getLowWatermark

public long getLowWatermark()

Specified by:

getLowWatermark in interface Store

setLowWatermark

public void setLowWatermark(long lowWatermark)

Specified by:

setLowWatermark in interface Store

getPersistenceType

public PersistenceType getPersistenceType()

Specified by:

getPersistenceType in interface Store

setPersistenceType

public void setPersistenceType(PersistenceType persistenceType)

Specified by:

setPersistenceType in interface Store

getRoutingStrategy

public RoutingStrategy getRoutingStrategy()

Specified by:

getRoutingStrategy in interface Store

getReadStrategy

public ReadStrategy getReadStrategy()

Specified by:

getReadStrategy in interface Store

getOffLinePushStrategy

public OfflinePushStrategy getOffLinePushStrategy()

Specified by:

getOffLinePushStrategy in interface Store

getLargestUsedVersionNumber

public int getLargestUsedVersionNumber()

Specified by:

getLargestUsedVersionNumber in interface Store

setLargestUsedVersionNumber

public void setLargestUsedVersionNumber(int largestUsedVersionNumber)

Specified by:

setLargestUsedVersionNumber in interface Store

getLargestUsedRTVersionNumber

public int getLargestUsedRTVersionNumber()

Specified by:

getLargestUsedRTVersionNumber in interface Store

setLargestUsedRTVersionNumber

public void setLargestUsedRTVersionNumber(int largestUsedRTVersionNumber)

Specified by:

setLargestUsedRTVersionNumber in interface Store

getStorageQuotaInByte

public long getStorageQuotaInByte()

Specified by:

getStorageQuotaInByte in interface Store

setStorageQuotaInByte

public void setStorageQuotaInByte(long storageQuotaInByte)

Specified by:

setStorageQuotaInByte in interface Store

getPartitionCount

public int getPartitionCount()

Specified by:

getPartitionCount in interface Store

setPartitionCount

public void setPartitionCount(int partitionCount)

Specified by:

setPartitionCount in interface Store

getPartitionerConfig

public PartitionerConfig getPartitionerConfig()

Specified by:

getPartitionerConfig in interface Store

setPartitionerConfig

public void setPartitionerConfig(PartitionerConfig value)

Specified by:

setPartitionerConfig in interface Store

cloneStoreProperties

public StoreProperties cloneStoreProperties()

isEnableWrites

public boolean isEnableWrites()

Specified by:

isEnableWrites in interface Store

setEnableWrites

public void setEnableWrites(boolean enableWrites)

Specified by:

setEnableWrites in interface Store

isEnableReads

public boolean isEnableReads()

Specified by:

isEnableReads in interface Store

setEnableReads

public void setEnableReads(boolean enableReads)

Specified by:

setEnableReads in interface Store

getReadQuotaInCU

public long getReadQuotaInCU()

Specified by:

getReadQuotaInCU in interface Store

setReadQuotaInCU

public void setReadQuotaInCU(long readQuotaInCU)

Specified by:

setReadQuotaInCU in interface Store

getHybridStoreConfig

public HybridStoreConfig getHybridStoreConfig()

Specified by:

getHybridStoreConfig in interface Store

setHybridStoreConfig

public void setHybridStoreConfig(HybridStoreConfig hybridStoreConfig)

Specified by:

setHybridStoreConfig in interface Store

getViewConfigs

public Map<String,ViewConfig> getViewConfigs()

Specified by:

getViewConfigs in interface Store

setViewConfigs

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

Specified by:

setViewConfigs in interface Store

isHybrid

public boolean isHybrid()

Specified by:

isHybrid in interface Store

getCompressionStrategy

public CompressionStrategy getCompressionStrategy()

Specified by:

getCompressionStrategy in interface Store

setCompressionStrategy

public void setCompressionStrategy(CompressionStrategy compressionStrategy)

Specified by:

setCompressionStrategy in interface Store

getClientDecompressionEnabled

public boolean getClientDecompressionEnabled()

Specified by:

getClientDecompressionEnabled in interface Store

setClientDecompressionEnabled

public void setClientDecompressionEnabled(boolean clientDecompressionEnabled)

Specified by:

setClientDecompressionEnabled in interface Store

isChunkingEnabled

public boolean isChunkingEnabled()

Specified by:

isChunkingEnabled in interface Store

setChunkingEnabled

public void setChunkingEnabled(boolean chunkingEnabled)

Specified by:

setChunkingEnabled in interface Store

isRmdChunkingEnabled

public boolean isRmdChunkingEnabled()

Specified by:

isRmdChunkingEnabled in interface Store

setRmdChunkingEnabled

public void setRmdChunkingEnabled(boolean rmdChunkingEnabled)

Specified by:

setRmdChunkingEnabled in interface Store

getBatchGetLimit

public int getBatchGetLimit()

Specified by:

getBatchGetLimit in interface Store

setBatchGetLimit

public void setBatchGetLimit(int batchGetLimit)

Specified by:

setBatchGetLimit in interface Store

isIncrementalPushEnabled

public boolean isIncrementalPushEnabled()

Specified by:

isIncrementalPushEnabled in interface Store

setIncrementalPushEnabled

public void setIncrementalPushEnabled(boolean incrementalPushEnabled)

Specified by:

setIncrementalPushEnabled in interface Store

isSeparateRealTimeTopicEnabled

public boolean isSeparateRealTimeTopicEnabled()

Specified by:

isSeparateRealTimeTopicEnabled in interface Store

setSeparateRealTimeTopicEnabled

public void setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled)

Specified by:

setSeparateRealTimeTopicEnabled in interface Store

isAccessControlled

public boolean isAccessControlled()

Specified by:

isAccessControlled in interface Store

setAccessControlled

public void setAccessControlled(boolean accessControlled)

Specified by:

setAccessControlled in interface Store

isMigrating

public boolean isMigrating()

Specified by:

isMigrating in interface Store

setMigrating

public void setMigrating(boolean migrating)

Specified by:

setMigrating in interface Store

getNumVersionsToPreserve

public int getNumVersionsToPreserve()

Specified by:

getNumVersionsToPreserve in interface Store

setNumVersionsToPreserve

public void setNumVersionsToPreserve(int numVersionsToPreserve)

Specified by:

setNumVersionsToPreserve in interface Store

isWriteComputationEnabled

public boolean isWriteComputationEnabled()

Specified by:

isWriteComputationEnabled in interface Store

setWriteComputationEnabled

public void setWriteComputationEnabled(boolean writeComputationEnabled)

Specified by:

setWriteComputationEnabled in interface Store

isReadComputationEnabled

public boolean isReadComputationEnabled()

Specified by:

isReadComputationEnabled in interface Store

setReadComputationEnabled

public void setReadComputationEnabled(boolean readComputationEnabled)

Specified by:

setReadComputationEnabled in interface Store

getBootstrapToOnlineTimeoutInHours

public int getBootstrapToOnlineTimeoutInHours()

Specified by:

getBootstrapToOnlineTimeoutInHours in interface Store

setBootstrapToOnlineTimeoutInHours

public void setBootstrapToOnlineTimeoutInHours(int bootstrapToOnlineTimeoutInHours)

Specified by:

setBootstrapToOnlineTimeoutInHours in interface Store

getPushStreamSourceAddress

public String getPushStreamSourceAddress()

Specified by:

getPushStreamSourceAddress in interface Store

setPushStreamSourceAddress

public void setPushStreamSourceAddress(String sourceAddress)

Specified by:

setPushStreamSourceAddress in interface Store

isNativeReplicationEnabled

public boolean isNativeReplicationEnabled()

Specified by:

isNativeReplicationEnabled in interface Store

getRmdVersion

public int getRmdVersion()

Specified by:

getRmdVersion in interface Store

setRmdVersion

public void setRmdVersion(int rmdVersion)

Specified by:

setRmdVersion in interface Store

setNativeReplicationEnabled

public void setNativeReplicationEnabled(boolean nativeReplicationEnabled)

Specified by:

setNativeReplicationEnabled in interface Store

getBackupStrategy

public BackupStrategy getBackupStrategy()

Specified by:

getBackupStrategy in interface Store

setBackupStrategy

public void setBackupStrategy(BackupStrategy value)

Specified by:

setBackupStrategy in interface Store

isSchemaAutoRegisterFromPushJobEnabled

public boolean isSchemaAutoRegisterFromPushJobEnabled()

Specified by:

isSchemaAutoRegisterFromPushJobEnabled in interface Store

setSchemaAutoRegisterFromPushJobEnabled

public void setSchemaAutoRegisterFromPushJobEnabled(boolean value)

Specified by:

setSchemaAutoRegisterFromPushJobEnabled in interface Store

getLatestSuperSetValueSchemaId

public int getLatestSuperSetValueSchemaId()

Specified by:

getLatestSuperSetValueSchemaId in interface Store

setLatestSuperSetValueSchemaId

public void setLatestSuperSetValueSchemaId(int valueSchemaId)

Specified by:

setLatestSuperSetValueSchemaId in interface Store

isHybridStoreDiskQuotaEnabled

public boolean isHybridStoreDiskQuotaEnabled()

Specified by:

isHybridStoreDiskQuotaEnabled in interface Store

setHybridStoreDiskQuotaEnabled

public void setHybridStoreDiskQuotaEnabled(boolean enabled)

Specified by:

setHybridStoreDiskQuotaEnabled in interface Store

getEtlStoreConfig

public ETLStoreConfig getEtlStoreConfig()

Specified by:

getEtlStoreConfig in interface Store

setEtlStoreConfig

public void setEtlStoreConfig(ETLStoreConfig etlStoreConfig)

Specified by:

setEtlStoreConfig in interface Store

isStoreMetadataSystemStoreEnabled

public boolean isStoreMetadataSystemStoreEnabled()

Specified by:

isStoreMetadataSystemStoreEnabled in interface Store

setStoreMetadataSystemStoreEnabled

public void setStoreMetadataSystemStoreEnabled(boolean storeMetadataSystemStoreEnabled)

Specified by:

setStoreMetadataSystemStoreEnabled in interface Store

isStoreMetaSystemStoreEnabled

public boolean isStoreMetaSystemStoreEnabled()

Specified by:

isStoreMetaSystemStoreEnabled in interface Store

setStoreMetaSystemStoreEnabled

public void setStoreMetaSystemStoreEnabled(boolean storeMetaSystemStoreEnabled)

Specified by:

setStoreMetaSystemStoreEnabled in interface Store

getLatestVersionPromoteToCurrentTimestamp

public long getLatestVersionPromoteToCurrentTimestamp()

Specified by:

getLatestVersionPromoteToCurrentTimestamp in interface Store

setLatestVersionPromoteToCurrentTimestamp

public void setLatestVersionPromoteToCurrentTimestamp(long latestVersionPromoteToCurrentTimestamp)

Specified by:

setLatestVersionPromoteToCurrentTimestamp in interface Store

getBackupVersionRetentionMs

public long getBackupVersionRetentionMs()

Specified by:

getBackupVersionRetentionMs in interface Store

setBackupVersionRetentionMs

public void setBackupVersionRetentionMs(long backupVersionRetentionMs)

Specified by:

setBackupVersionRetentionMs in interface Store

getRetentionTime

public long getRetentionTime()

Specified by:

getRetentionTime in interface Store

getReplicationFactor

public int getReplicationFactor()

Specified by:

getReplicationFactor in interface Store

setReplicationFactor

public void setReplicationFactor(int replicationFactor)

Specified by:

setReplicationFactor in interface Store

isMigrationDuplicateStore

public boolean isMigrationDuplicateStore()

Specified by:

isMigrationDuplicateStore in interface Store

setMigrationDuplicateStore

public void setMigrationDuplicateStore(boolean migrationDuplicateStore)

Specified by:

setMigrationDuplicateStore in interface Store

getNativeReplicationSourceFabric

public String getNativeReplicationSourceFabric()

Specified by:

getNativeReplicationSourceFabric in interface Store

setNativeReplicationSourceFabric

public void setNativeReplicationSourceFabric(String nativeReplicationSourceFabric)

Specified by:

setNativeReplicationSourceFabric in interface Store

isActiveActiveReplicationEnabled

public boolean isActiveActiveReplicationEnabled()

Specified by:

isActiveActiveReplicationEnabled in interface Store

setActiveActiveReplicationEnabled

public void setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled)

Specified by:

setActiveActiveReplicationEnabled in interface Store

getSystemStores

public Map<String,SystemStoreAttributes> getSystemStores()

Specified by:

getSystemStores in interface Store

setSystemStores

public void setSystemStores(Map<String,SystemStoreAttributes> systemStores)

Specified by:

setSystemStores in interface Store

putSystemStore

public void putSystemStore(VeniceSystemStoreType systemStoreType,
 SystemStoreAttributes systemStoreAttributes)

Specified by:

putSystemStore in interface Store

isDaVinciPushStatusStoreEnabled

public boolean isDaVinciPushStatusStoreEnabled()

Specified by:

isDaVinciPushStatusStoreEnabled in interface Store

setDaVinciPushStatusStoreEnabled

public void setDaVinciPushStatusStoreEnabled(boolean daVinciPushStatusStoreEnabled)

Specified by:

setDaVinciPushStatusStoreEnabled in interface Store

cloneStore

public Store cloneStore()

Specified by:

cloneStore in interface Store

getVersions

public List<Version> getVersions()

Specified by:

getVersions in interface Store

setVersions

public void setVersions(List<Version> versions)

Specified by:

setVersions in interface Store

addVersion

public void addVersion(Version version)

Specified by:

addVersion in interface Store

addVersion

public void addVersion(Version version,
 boolean isClonedVersion,
 int currentRTVersionNumber)

Specified by:

addVersion in interface Store

forceAddVersion

public void forceAddVersion(Version version,
 boolean isClonedVersion)

Specified by:

forceAddVersion in interface Store

checkDisableStoreWrite

public void checkDisableStoreWrite(String action,
 int version)

Specified by:

checkDisableStoreWrite in interface Store

deleteVersion

public Version deleteVersion(int versionNumber)

Specified by:

deleteVersion in interface Store

containsVersion

public boolean containsVersion(int versionNumber)

Specified by:

containsVersion in interface Store

updateVersionStatus

public void updateVersionStatus(int versionNumber,
 VersionStatus status)

Specified by:

updateVersionStatus in interface Store

peekNextVersionNumber

public int peekNextVersionNumber()

Specified by:

peekNextVersionNumber in interface Store

getVersion

@Nullable
public Version getVersion(int versionNumber)

Specified by:

getVersion in interface Store

Parameters:

versionNumber - for which to get the Version

Returns:

the Version corresponding to the provided , or null if no such version exists

getVersionOrThrow

@Nonnull
public Version getVersionOrThrow(int versionNumber)
                          throws StoreVersionNotFoundException

Specified by:

getVersionOrThrow in interface Store

Throws:

StoreVersionNotFoundException

getVersionStatus

public VersionStatus getVersionStatus(int versionNumber)

Specified by:

getVersionStatus in interface Store

retrieveVersionsToDelete

public List<Version> retrieveVersionsToDelete(int clusterNumVersionsToPreserve)

Specified by:

retrieveVersionsToDelete in interface Store

isSystemStore

public boolean isSystemStore()

Specified by:

isSystemStore in interface Store

fixMissingFields

public void fixMissingFields()

Specified by:

fixMissingFields in interface Store

isStorageNodeReadQuotaEnabled

public boolean isStorageNodeReadQuotaEnabled()

Specified by:

isStorageNodeReadQuotaEnabled in interface Store

setStorageNodeReadQuotaEnabled

public void setStorageNodeReadQuotaEnabled(boolean storageNodeReadQuotaEnabled)

Specified by:

setStorageNodeReadQuotaEnabled in interface Store

isCompactionEnabled

public boolean isCompactionEnabled()

Specified by:

isCompactionEnabled in interface Store

setCompactionEnabled

public void setCompactionEnabled(boolean compactionEnabled)

Specified by:

setCompactionEnabled in interface Store

getCompactionThresholdMilliseconds

public long getCompactionThresholdMilliseconds()

Specified by:

getCompactionThresholdMilliseconds in interface Store

setCompactionThresholdMilliseconds

public void setCompactionThresholdMilliseconds(long compactionThreshold)

Specified by:

setCompactionThresholdMilliseconds in interface Store

getMinCompactionLagSeconds

public long getMinCompactionLagSeconds()

Specified by:

getMinCompactionLagSeconds in interface Store

setMinCompactionLagSeconds

public void setMinCompactionLagSeconds(long minCompactionLagSeconds)

Specified by:

setMinCompactionLagSeconds in interface Store

getMaxCompactionLagSeconds

public long getMaxCompactionLagSeconds()

Specified by:

getMaxCompactionLagSeconds in interface Store

setMaxCompactionLagSeconds

public void setMaxCompactionLagSeconds(long maxCompactionLagSeconds)

Specified by:

setMaxCompactionLagSeconds in interface Store

getMaxRecordSizeBytes

public int getMaxRecordSizeBytes()

Specified by:

getMaxRecordSizeBytes in interface Store

setMaxRecordSizeBytes

public void setMaxRecordSizeBytes(int maxRecordSizeBytes)

Specified by:

setMaxRecordSizeBytes in interface Store

getMaxNearlineRecordSizeBytes

public int getMaxNearlineRecordSizeBytes()

Specified by:

getMaxNearlineRecordSizeBytes in interface Store

setMaxNearlineRecordSizeBytes

public void setMaxNearlineRecordSizeBytes(int maxNearlineRecordSizeBytes)

Specified by:

setMaxNearlineRecordSizeBytes in interface Store

setUnusedSchemaDeletionEnabled

public void setUnusedSchemaDeletionEnabled(boolean unusedSchemaDeletionEnabled)

Specified by:

setUnusedSchemaDeletionEnabled in interface Store

isUnusedSchemaDeletionEnabled

public boolean isUnusedSchemaDeletionEnabled()

Specified by:

isUnusedSchemaDeletionEnabled in interface Store

setBlobTransferEnabled

public void setBlobTransferEnabled(boolean blobTransferEnabled)

Specified by:

setBlobTransferEnabled in interface Store

isBlobTransferEnabled

public boolean isBlobTransferEnabled()

Specified by:

isBlobTransferEnabled in interface Store

setBlobTransferInServerEnabled

public void setBlobTransferInServerEnabled(String blobTransferInServerEnabled)

Specified by:

setBlobTransferInServerEnabled in interface Store

getBlobTransferInServerEnabled

public String getBlobTransferInServerEnabled()

Specified by:

getBlobTransferInServerEnabled in interface Store

isNearlineProducerCompressionEnabled

public boolean isNearlineProducerCompressionEnabled()

Specified by:

isNearlineProducerCompressionEnabled in interface Store

setNearlineProducerCompressionEnabled

public void setNearlineProducerCompressionEnabled(boolean compressionEnabled)

Specified by:

setNearlineProducerCompressionEnabled in interface Store

getNearlineProducerCountPerWriter

public int getNearlineProducerCountPerWriter()

Specified by:

getNearlineProducerCountPerWriter in interface Store

setNearlineProducerCountPerWriter

public void setNearlineProducerCountPerWriter(int producerCnt)

Specified by:

setNearlineProducerCountPerWriter in interface Store

getTargetSwapRegion

public String getTargetSwapRegion()

Specified by:

getTargetSwapRegion in interface Store

getTargetSwapRegionWaitTime

public int getTargetSwapRegionWaitTime()

Specified by:

getTargetSwapRegionWaitTime in interface Store

setTargetSwapRegion

public void setTargetSwapRegion(String targetRegion)

Specified by:

setTargetSwapRegion in interface Store

setTargetSwapRegionWaitTime

public void setTargetSwapRegionWaitTime(int waitTime)

Specified by:

setTargetSwapRegionWaitTime in interface Store

setIsDavinciHeartbeatReported

public void setIsDavinciHeartbeatReported(boolean isReported)

Specified by:

setIsDavinciHeartbeatReported in interface Store

getIsDavinciHeartbeatReported

public boolean getIsDavinciHeartbeatReported()

Specified by:

getIsDavinciHeartbeatReported in interface Store

updateVersionForDaVinciHeartbeat

public void updateVersionForDaVinciHeartbeat(int versionNumber,
 boolean reported)

Specified by:

updateVersionForDaVinciHeartbeat in interface Store

isGlobalRtDivEnabled

public boolean isGlobalRtDivEnabled()

Specified by:

isGlobalRtDivEnabled in interface Store

setGlobalRtDivEnabled

public void setGlobalRtDivEnabled(boolean globalRtDivEnabled)

Specified by:

setGlobalRtDivEnabled in interface Store

isTTLRepushEnabled

public boolean isTTLRepushEnabled()

Specified by:

isTTLRepushEnabled in interface Store

setTTLRepushEnabled

public void setTTLRepushEnabled(boolean ttlRepushEnabled)

Specified by:

setTTLRepushEnabled in interface Store

isEnumSchemaEvolutionAllowed

public boolean isEnumSchemaEvolutionAllowed()

Specified by:

isEnumSchemaEvolutionAllowed in interface Store

setEnumSchemaEvolutionAllowed

public void setEnumSchemaEvolutionAllowed(boolean enumSchemaEvolutionAllowed)

Specified by:

setEnumSchemaEvolutionAllowed in interface Store

getStoreLifecycleHooks

public List<LifecycleHooksRecord> getStoreLifecycleHooks()

Specified by:

getStoreLifecycleHooks in interface Store

setStoreLifecycleHooks

public void setStoreLifecycleHooks(List<LifecycleHooksRecord> storeLifecycleHooks)

Specified by:

setStoreLifecycleHooks in interface Store

setKeyUrnCompressionEnabled

public void setKeyUrnCompressionEnabled(boolean keyUrnCompressionEnabled)

Specified by:

setKeyUrnCompressionEnabled in interface Store

isKeyUrnCompressionEnabled

public boolean isKeyUrnCompressionEnabled()

Specified by:

isKeyUrnCompressionEnabled in interface Store

setKeyUrnFields

public void setKeyUrnFields(List<String> keyUrnFieldList)

Specified by:

setKeyUrnFields in interface Store

getKeyUrnFields

public List<String> getKeyUrnFields()

Specified by:

getKeyUrnFields in interface Store

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