Package com.linkedin.venice.meta
Class ReadOnlyStore
- java.lang.Object
-
- com.linkedin.venice.meta.ReadOnlyStore
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ReadOnlyStore.ReadOnlyVersion
A read-only wrapper ofVersion
-
Field Summary
-
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, storeNamePattern, SYSTEM_STORE_FORMAT, SYSTEM_STORE_NAME_PREFIX, UNLIMITED_STORAGE_QUOTA
-
-
Constructor Summary
Constructors Constructor Description ReadOnlyStore(Store delegate)
-
Method Summary
-
-
-
Constructor Detail
-
ReadOnlyStore
public ReadOnlyStore(Store delegate)
-
-
Method Detail
-
getCreatedTime
public long getCreatedTime()
- Specified by:
getCreatedTime
in interfaceStore
-
getCurrentVersion
public int getCurrentVersion()
- Specified by:
getCurrentVersion
in interfaceStore
-
setCurrentVersion
public void setCurrentVersion(int currentVersion)
- Specified by:
setCurrentVersion
in interfaceStore
-
setCurrentVersionWithoutCheck
public void setCurrentVersionWithoutCheck(int currentVersion)
- Specified by:
setCurrentVersionWithoutCheck
in interfaceStore
-
getLowWatermark
public long getLowWatermark()
- Specified by:
getLowWatermark
in interfaceStore
-
setLowWatermark
public void setLowWatermark(long lowWatermark)
- Specified by:
setLowWatermark
in interfaceStore
-
getPersistenceType
public PersistenceType getPersistenceType()
- Specified by:
getPersistenceType
in interfaceStore
-
setPersistenceType
public void setPersistenceType(PersistenceType persistenceType)
- Specified by:
setPersistenceType
in interfaceStore
-
getRoutingStrategy
public RoutingStrategy getRoutingStrategy()
- Specified by:
getRoutingStrategy
in interfaceStore
-
getReadStrategy
public ReadStrategy getReadStrategy()
- Specified by:
getReadStrategy
in interfaceStore
-
getOffLinePushStrategy
public OfflinePushStrategy getOffLinePushStrategy()
- Specified by:
getOffLinePushStrategy
in interfaceStore
-
getLargestUsedVersionNumber
public int getLargestUsedVersionNumber()
- Specified by:
getLargestUsedVersionNumber
in interfaceStore
-
setLargestUsedVersionNumber
public void setLargestUsedVersionNumber(int largestUsedVersionNumber)
- Specified by:
setLargestUsedVersionNumber
in interfaceStore
-
getStorageQuotaInByte
public long getStorageQuotaInByte()
- Specified by:
getStorageQuotaInByte
in interfaceStore
-
setStorageQuotaInByte
public void setStorageQuotaInByte(long storageQuotaInByte)
- Specified by:
setStorageQuotaInByte
in interfaceStore
-
getPartitionCount
public int getPartitionCount()
- Specified by:
getPartitionCount
in interfaceStore
-
setPartitionCount
public void setPartitionCount(int partitionCount)
- Specified by:
setPartitionCount
in interfaceStore
-
getPartitionerConfig
public PartitionerConfig getPartitionerConfig()
- Specified by:
getPartitionerConfig
in interfaceStore
-
setPartitionerConfig
public void setPartitionerConfig(PartitionerConfig value)
- Specified by:
setPartitionerConfig
in interfaceStore
-
isEnableWrites
public boolean isEnableWrites()
- Specified by:
isEnableWrites
in interfaceStore
-
setEnableWrites
public void setEnableWrites(boolean enableWrites)
- Specified by:
setEnableWrites
in interfaceStore
-
isEnableReads
public boolean isEnableReads()
- Specified by:
isEnableReads
in interfaceStore
-
setEnableReads
public void setEnableReads(boolean enableReads)
- Specified by:
setEnableReads
in interfaceStore
-
getReadQuotaInCU
public long getReadQuotaInCU()
- Specified by:
getReadQuotaInCU
in interfaceStore
-
setReadQuotaInCU
public void setReadQuotaInCU(long readQuotaInCU)
- Specified by:
setReadQuotaInCU
in interfaceStore
-
getHybridStoreConfig
public HybridStoreConfig getHybridStoreConfig()
- Specified by:
getHybridStoreConfig
in interfaceStore
-
setHybridStoreConfig
public void setHybridStoreConfig(HybridStoreConfig hybridStoreConfig)
- Specified by:
setHybridStoreConfig
in interfaceStore
-
getViewConfigs
public java.util.Map<java.lang.String,ViewConfig> getViewConfigs()
- Specified by:
getViewConfigs
in interfaceStore
-
setViewConfigs
public void setViewConfigs(java.util.Map<java.lang.String,ViewConfig> viewConfigList)
- Specified by:
setViewConfigs
in interfaceStore
-
getCompressionStrategy
public CompressionStrategy getCompressionStrategy()
- Specified by:
getCompressionStrategy
in interfaceStore
-
setCompressionStrategy
public void setCompressionStrategy(CompressionStrategy compressionStrategy)
- Specified by:
setCompressionStrategy
in interfaceStore
-
getClientDecompressionEnabled
public boolean getClientDecompressionEnabled()
- Specified by:
getClientDecompressionEnabled
in interfaceStore
-
setClientDecompressionEnabled
public void setClientDecompressionEnabled(boolean clientDecompressionEnabled)
- Specified by:
setClientDecompressionEnabled
in interfaceStore
-
isChunkingEnabled
public boolean isChunkingEnabled()
- Specified by:
isChunkingEnabled
in interfaceStore
-
setChunkingEnabled
public void setChunkingEnabled(boolean chunkingEnabled)
- Specified by:
setChunkingEnabled
in interfaceStore
-
isRmdChunkingEnabled
public boolean isRmdChunkingEnabled()
- Specified by:
isRmdChunkingEnabled
in interfaceStore
-
setRmdChunkingEnabled
public void setRmdChunkingEnabled(boolean rmdChunkingEnabled)
- Specified by:
setRmdChunkingEnabled
in interfaceStore
-
getBatchGetLimit
public int getBatchGetLimit()
- Specified by:
getBatchGetLimit
in interfaceStore
-
setBatchGetLimit
public void setBatchGetLimit(int batchGetLimit)
- Specified by:
setBatchGetLimit
in interfaceStore
-
isIncrementalPushEnabled
public boolean isIncrementalPushEnabled()
- Specified by:
isIncrementalPushEnabled
in interfaceStore
-
setIncrementalPushEnabled
public void setIncrementalPushEnabled(boolean incrementalPushEnabled)
- Specified by:
setIncrementalPushEnabled
in interfaceStore
-
isSeparateRealTimeTopicEnabled
public boolean isSeparateRealTimeTopicEnabled()
- Specified by:
isSeparateRealTimeTopicEnabled
in interfaceStore
-
setSeparateRealTimeTopicEnabled
public void setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled)
- Specified by:
setSeparateRealTimeTopicEnabled
in interfaceStore
-
isAccessControlled
public boolean isAccessControlled()
- Specified by:
isAccessControlled
in interfaceStore
-
setAccessControlled
public void setAccessControlled(boolean accessControlled)
- Specified by:
setAccessControlled
in interfaceStore
-
isMigrating
public boolean isMigrating()
- Specified by:
isMigrating
in interfaceStore
-
setMigrating
public void setMigrating(boolean migrating)
- Specified by:
setMigrating
in interfaceStore
-
getNumVersionsToPreserve
public int getNumVersionsToPreserve()
- Specified by:
getNumVersionsToPreserve
in interfaceStore
-
setNumVersionsToPreserve
public void setNumVersionsToPreserve(int numVersionsToPreserve)
- Specified by:
setNumVersionsToPreserve
in interfaceStore
-
isWriteComputationEnabled
public boolean isWriteComputationEnabled()
- Specified by:
isWriteComputationEnabled
in interfaceStore
-
setWriteComputationEnabled
public void setWriteComputationEnabled(boolean writeComputationEnabled)
- Specified by:
setWriteComputationEnabled
in interfaceStore
-
isReadComputationEnabled
public boolean isReadComputationEnabled()
- Specified by:
isReadComputationEnabled
in interfaceStore
-
setReadComputationEnabled
public void setReadComputationEnabled(boolean readComputationEnabled)
- Specified by:
setReadComputationEnabled
in interfaceStore
-
getBootstrapToOnlineTimeoutInHours
public int getBootstrapToOnlineTimeoutInHours()
- Specified by:
getBootstrapToOnlineTimeoutInHours
in interfaceStore
-
setBootstrapToOnlineTimeoutInHours
public void setBootstrapToOnlineTimeoutInHours(int bootstrapToOnlineTimeoutInHours)
- Specified by:
setBootstrapToOnlineTimeoutInHours
in interfaceStore
-
getPushStreamSourceAddress
public java.lang.String getPushStreamSourceAddress()
- Specified by:
getPushStreamSourceAddress
in interfaceStore
-
setPushStreamSourceAddress
public void setPushStreamSourceAddress(java.lang.String sourceAddress)
- Specified by:
setPushStreamSourceAddress
in interfaceStore
-
isNativeReplicationEnabled
public boolean isNativeReplicationEnabled()
- Specified by:
isNativeReplicationEnabled
in interfaceStore
-
getRmdVersion
public int getRmdVersion()
- Specified by:
getRmdVersion
in interfaceStore
-
setRmdVersion
public void setRmdVersion(int rmdVersion)
- Specified by:
setRmdVersion
in interfaceStore
-
setNativeReplicationEnabled
public void setNativeReplicationEnabled(boolean nativeReplicationEnabled)
- Specified by:
setNativeReplicationEnabled
in interfaceStore
-
getBackupStrategy
public BackupStrategy getBackupStrategy()
- Specified by:
getBackupStrategy
in interfaceStore
-
setBackupStrategy
public void setBackupStrategy(BackupStrategy value)
- Specified by:
setBackupStrategy
in interfaceStore
-
isSchemaAutoRegisterFromPushJobEnabled
public boolean isSchemaAutoRegisterFromPushJobEnabled()
- Specified by:
isSchemaAutoRegisterFromPushJobEnabled
in interfaceStore
-
setSchemaAutoRegisterFromPushJobEnabled
public void setSchemaAutoRegisterFromPushJobEnabled(boolean value)
- Specified by:
setSchemaAutoRegisterFromPushJobEnabled
in interfaceStore
-
getLatestSuperSetValueSchemaId
public int getLatestSuperSetValueSchemaId()
- Specified by:
getLatestSuperSetValueSchemaId
in interfaceStore
-
setLatestSuperSetValueSchemaId
public void setLatestSuperSetValueSchemaId(int valueSchemaId)
- Specified by:
setLatestSuperSetValueSchemaId
in interfaceStore
-
isHybridStoreDiskQuotaEnabled
public boolean isHybridStoreDiskQuotaEnabled()
- Specified by:
isHybridStoreDiskQuotaEnabled
in interfaceStore
-
setHybridStoreDiskQuotaEnabled
public void setHybridStoreDiskQuotaEnabled(boolean enabled)
- Specified by:
setHybridStoreDiskQuotaEnabled
in interfaceStore
-
getEtlStoreConfig
public ETLStoreConfig getEtlStoreConfig()
- Specified by:
getEtlStoreConfig
in interfaceStore
-
setEtlStoreConfig
public void setEtlStoreConfig(ETLStoreConfig etlStoreConfig)
- Specified by:
setEtlStoreConfig
in interfaceStore
-
isStoreMetadataSystemStoreEnabled
public boolean isStoreMetadataSystemStoreEnabled()
- Specified by:
isStoreMetadataSystemStoreEnabled
in interfaceStore
-
setStoreMetadataSystemStoreEnabled
public void setStoreMetadataSystemStoreEnabled(boolean storeMetadataSystemStoreEnabled)
- Specified by:
setStoreMetadataSystemStoreEnabled
in interfaceStore
-
isStoreMetaSystemStoreEnabled
public boolean isStoreMetaSystemStoreEnabled()
- Specified by:
isStoreMetaSystemStoreEnabled
in interfaceStore
-
setStoreMetaSystemStoreEnabled
public void setStoreMetaSystemStoreEnabled(boolean storeMetaSystemStoreEnabled)
- Specified by:
setStoreMetaSystemStoreEnabled
in interfaceStore
-
getLatestVersionPromoteToCurrentTimestamp
public long getLatestVersionPromoteToCurrentTimestamp()
- Specified by:
getLatestVersionPromoteToCurrentTimestamp
in interfaceStore
-
setLatestVersionPromoteToCurrentTimestamp
public void setLatestVersionPromoteToCurrentTimestamp(long latestVersionPromoteToCurrentTimestamp)
- Specified by:
setLatestVersionPromoteToCurrentTimestamp
in interfaceStore
-
getBackupVersionRetentionMs
public long getBackupVersionRetentionMs()
- Specified by:
getBackupVersionRetentionMs
in interfaceStore
-
setBackupVersionRetentionMs
public void setBackupVersionRetentionMs(long backupVersionRetentionMs)
- Specified by:
setBackupVersionRetentionMs
in interfaceStore
-
getRetentionTime
public long getRetentionTime()
- Specified by:
getRetentionTime
in interfaceStore
-
getReplicationFactor
public int getReplicationFactor()
- Specified by:
getReplicationFactor
in interfaceStore
-
setReplicationFactor
public void setReplicationFactor(int replicationFactor)
- Specified by:
setReplicationFactor
in interfaceStore
-
isMigrationDuplicateStore
public boolean isMigrationDuplicateStore()
- Specified by:
isMigrationDuplicateStore
in interfaceStore
-
setMigrationDuplicateStore
public void setMigrationDuplicateStore(boolean migrationDuplicateStore)
- Specified by:
setMigrationDuplicateStore
in interfaceStore
-
getNativeReplicationSourceFabric
public java.lang.String getNativeReplicationSourceFabric()
- Specified by:
getNativeReplicationSourceFabric
in interfaceStore
-
setNativeReplicationSourceFabric
public void setNativeReplicationSourceFabric(java.lang.String nativeReplicationSourceFabric)
- Specified by:
setNativeReplicationSourceFabric
in interfaceStore
-
isActiveActiveReplicationEnabled
public boolean isActiveActiveReplicationEnabled()
- Specified by:
isActiveActiveReplicationEnabled
in interfaceStore
-
setActiveActiveReplicationEnabled
public void setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled)
- Specified by:
setActiveActiveReplicationEnabled
in interfaceStore
-
getSystemStores
public java.util.Map<java.lang.String,SystemStoreAttributes> getSystemStores()
- Specified by:
getSystemStores
in interfaceStore
-
setSystemStores
public void setSystemStores(java.util.Map<java.lang.String,SystemStoreAttributes> systemStores)
- Specified by:
setSystemStores
in interfaceStore
-
putSystemStore
public void putSystemStore(VeniceSystemStoreType systemStoreType, SystemStoreAttributes systemStoreAttributes)
- Specified by:
putSystemStore
in interfaceStore
-
isDaVinciPushStatusStoreEnabled
public boolean isDaVinciPushStatusStoreEnabled()
- Specified by:
isDaVinciPushStatusStoreEnabled
in interfaceStore
-
setDaVinciPushStatusStoreEnabled
public void setDaVinciPushStatusStoreEnabled(boolean daVinciPushStatusStoreEnabled)
- Specified by:
setDaVinciPushStatusStoreEnabled
in interfaceStore
-
cloneStore
public Store cloneStore()
- Specified by:
cloneStore
in interfaceStore
-
getVersions
public java.util.List<Version> getVersions()
- Specified by:
getVersions
in interfaceStore
-
setVersions
public void setVersions(java.util.List<Version> versions)
- Specified by:
setVersions
in interfaceStore
-
addVersion
public void addVersion(Version version)
- Specified by:
addVersion
in interfaceStore
-
addVersion
public void addVersion(Version version, boolean isClonedVersion)
- Specified by:
addVersion
in interfaceStore
-
forceAddVersion
public void forceAddVersion(Version version, boolean isClonedVersion)
- Specified by:
forceAddVersion
in interfaceStore
-
checkDisableStoreWrite
public void checkDisableStoreWrite(java.lang.String action, int version)
- Specified by:
checkDisableStoreWrite
in interfaceStore
-
deleteVersion
public Version deleteVersion(int versionNumber)
- Specified by:
deleteVersion
in interfaceStore
-
containsVersion
public boolean containsVersion(int versionNumber)
- Specified by:
containsVersion
in interfaceStore
-
updateVersionStatus
public void updateVersionStatus(int versionNumber, VersionStatus status)
- Specified by:
updateVersionStatus
in interfaceStore
-
peekNextVersion
public Version peekNextVersion()
- Specified by:
peekNextVersion
in interfaceStore
-
getVersion
@Nullable public Version getVersion(int versionNumber)
- Specified by:
getVersion
in interfaceStore
- Parameters:
versionNumber
- for which to get theVersion
- Returns:
- the
Version
corresponding to the provided {@param versionNumber}, or null if no such version exists
-
getVersionOrThrow
@Nonnull public Version getVersionOrThrow(int versionNumber) throws StoreVersionNotFoundException
- Specified by:
getVersionOrThrow
in interfaceStore
- Throws:
StoreVersionNotFoundException
-
getVersionStatus
public VersionStatus getVersionStatus(int versionNumber)
- Specified by:
getVersionStatus
in interfaceStore
-
retrieveVersionsToDelete
public java.util.List<Version> retrieveVersionsToDelete(int clusterNumVersionsToPreserve)
- Specified by:
retrieveVersionsToDelete
in interfaceStore
-
isSystemStore
public boolean isSystemStore()
- Specified by:
isSystemStore
in interfaceStore
-
fixMissingFields
public void fixMissingFields()
- Specified by:
fixMissingFields
in interfaceStore
-
isStorageNodeReadQuotaEnabled
public boolean isStorageNodeReadQuotaEnabled()
- Specified by:
isStorageNodeReadQuotaEnabled
in interfaceStore
-
setStorageNodeReadQuotaEnabled
public void setStorageNodeReadQuotaEnabled(boolean storageNodeReadQuotaEnabled)
- Specified by:
setStorageNodeReadQuotaEnabled
in interfaceStore
-
getMinCompactionLagSeconds
public long getMinCompactionLagSeconds()
- Specified by:
getMinCompactionLagSeconds
in interfaceStore
-
setMinCompactionLagSeconds
public void setMinCompactionLagSeconds(long minCompactionLagSeconds)
- Specified by:
setMinCompactionLagSeconds
in interfaceStore
-
getMaxCompactionLagSeconds
public long getMaxCompactionLagSeconds()
- Specified by:
getMaxCompactionLagSeconds
in interfaceStore
-
setMaxCompactionLagSeconds
public void setMaxCompactionLagSeconds(long maxCompactionLagSeconds)
- Specified by:
setMaxCompactionLagSeconds
in interfaceStore
-
getMaxRecordSizeBytes
public int getMaxRecordSizeBytes()
- Specified by:
getMaxRecordSizeBytes
in interfaceStore
-
setMaxRecordSizeBytes
public void setMaxRecordSizeBytes(int maxRecordSizeBytes)
- Specified by:
setMaxRecordSizeBytes
in interfaceStore
-
getMaxNearlineRecordSizeBytes
public int getMaxNearlineRecordSizeBytes()
- Specified by:
getMaxNearlineRecordSizeBytes
in interfaceStore
-
setMaxNearlineRecordSizeBytes
public void setMaxNearlineRecordSizeBytes(int maxNearlineRecordSizeBytes)
- Specified by:
setMaxNearlineRecordSizeBytes
in interfaceStore
-
setUnusedSchemaDeletionEnabled
public void setUnusedSchemaDeletionEnabled(boolean unusedSchemaDeletionEnabled)
- Specified by:
setUnusedSchemaDeletionEnabled
in interfaceStore
-
isUnusedSchemaDeletionEnabled
public boolean isUnusedSchemaDeletionEnabled()
- Specified by:
isUnusedSchemaDeletionEnabled
in interfaceStore
-
setBlobTransferEnabled
public void setBlobTransferEnabled(boolean blobTransferEnabled)
- Specified by:
setBlobTransferEnabled
in interfaceStore
-
isBlobTransferEnabled
public boolean isBlobTransferEnabled()
- Specified by:
isBlobTransferEnabled
in interfaceStore
-
isNearlineProducerCompressionEnabled
public boolean isNearlineProducerCompressionEnabled()
- Specified by:
isNearlineProducerCompressionEnabled
in interfaceStore
-
setNearlineProducerCompressionEnabled
public void setNearlineProducerCompressionEnabled(boolean compressionEnabled)
- Specified by:
setNearlineProducerCompressionEnabled
in interfaceStore
-
getNearlineProducerCountPerWriter
public int getNearlineProducerCountPerWriter()
- Specified by:
getNearlineProducerCountPerWriter
in interfaceStore
-
setNearlineProducerCountPerWriter
public void setNearlineProducerCountPerWriter(int producerCnt)
- Specified by:
setNearlineProducerCountPerWriter
in interfaceStore
-
getTargetSwapRegion
public java.lang.String getTargetSwapRegion()
- Specified by:
getTargetSwapRegion
in interfaceStore
-
getTargetSwapRegionWaitTime
public int getTargetSwapRegionWaitTime()
- Specified by:
getTargetSwapRegionWaitTime
in interfaceStore
-
setTargetSwapRegion
public void setTargetSwapRegion(java.lang.String targetRegion)
- Specified by:
setTargetSwapRegion
in interfaceStore
-
setTargetSwapRegionWaitTime
public void setTargetSwapRegionWaitTime(int waitTime)
- Specified by:
setTargetSwapRegionWaitTime
in interfaceStore
-
setIsDavinciHeartbeatReported
public void setIsDavinciHeartbeatReported(boolean isReported)
- Specified by:
setIsDavinciHeartbeatReported
in interfaceStore
-
getIsDavinciHeartbeatReported
public boolean getIsDavinciHeartbeatReported()
- Specified by:
getIsDavinciHeartbeatReported
in interfaceStore
-
updateVersionForDaVinciHeartbeat
public void updateVersionForDaVinciHeartbeat(int versionNumber, boolean reported)
- Specified by:
updateVersionForDaVinciHeartbeat
in interfaceStore
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
-