Package com.linkedin.venice.meta
Class StoreInfo
- java.lang.Object
-
- com.linkedin.venice.meta.StoreInfo
-
public class StoreInfo extends java.lang.Object
Json-serializable class for sending store information to the controller client
-
-
Field Summary
Fields Modifier and Type Field Description int
replicationMetadataVersionId
RMD (Replication metadata) version ID on the store-level.
-
Constructor Summary
Constructors Constructor Description StoreInfo()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static StoreInfo
fromStore(Store store)
BackupStrategy
getBackupStrategy()
long
getBackupVersionRetentionMs()
int
getBatchGetLimit()
int
getBootstrapToOnlineTimeoutInHours()
boolean
getClientDecompressionEnabled()
java.util.Map<java.lang.String,java.lang.Integer>
getColoToCurrentVersions()
CompressionStrategy
getCompressionStrategy()
int
getCurrentVersion()
The version of the store which is currently being servedETLStoreConfig
getEtlStoreConfig()
HybridStoreConfig
getHybridStoreConfig()
boolean
getHybridStoreOverheadBypass()
java.lang.String
getKafkaBrokerUrl()
int
getLargestUsedVersionNumber()
int
getLatestSuperSetValueSchemaId()
long
getLowWatermark()
long
getMaxCompactionLagSeconds()
int
getMaxNearlineRecordSizeBytes()
int
getMaxRecordSizeBytes()
long
getMinCompactionLagSeconds()
java.lang.String
getName()
Store Namejava.lang.String
getNativeReplicationSourceFabric()
int
getNumVersionsToPreserve()
java.lang.String
getOwner()
Store Ownerint
getPartitionCount()
The number of partitions for this storePartitionerConfig
getPartitionerConfig()
java.lang.String
getPushStreamSourceAddress()
long
getReadQuotaInCU()
int
getReplicationFactor()
int
getReplicationMetadataVersionId()
int
getReservedVersion()
The highest version number that has been reserved.long
getStorageQuotaInByte()
java.util.Optional<Version>
getVersion(int versionNum)
java.util.List<Version>
getVersions()
List of available versions for this storejava.util.Map<java.lang.String,ViewConfig>
getViewConfigs()
boolean
isAccessControlled()
boolean
isActiveActiveReplicationEnabled()
boolean
isBatchGetRouterCacheEnabled()
boolean
isBlobTransferEnabled()
boolean
isChunkingEnabled()
boolean
isDaVinciPushStatusStoreEnabled()
boolean
isEnableStoreReads()
boolean
isEnableStoreWrites()
Whether the store is enableStoreWrites, a enableStoreWrites store cannot have new versions pushedboolean
isHybridStoreDiskQuotaEnabled()
boolean
isIncrementalPushEnabled()
boolean
isMigrating()
boolean
isMigrationDuplicateStore()
boolean
isNativeReplicationEnabled()
boolean
isReadComputationEnabled()
boolean
isRmdChunkingEnabled()
boolean
isSchemaAutoRegisterFromPushJobEnabled()
boolean
isSingleGetRouterCacheEnabled()
boolean
isStorageNodeReadQuotaEnabled()
boolean
isStoreMetadataSystemStoreEnabled()
boolean
isStoreMetaSystemStoreEnabled()
boolean
isSuperSetSchemaAutoGenerationForReadComputeEnabled()
boolean
isUnusedSchemaDeletionEnabled()
boolean
isWriteComputationEnabled()
void
setAccessControlled(boolean accessControlled)
void
setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled)
void
setBackupStrategy(BackupStrategy value)
void
setBackupVersionRetentionMs(long backupVersionRetentionMs)
void
setBatchGetLimit(int batchGetLimit)
void
setBatchGetRouterCacheEnabled(boolean batchGetRouterCacheEnabled)
void
setBlobTransferEnabled(boolean blobTransferEnabled)
void
setBootstrapToOnlineTimeoutInHours(int bootstrapToOnlineTimeoutInHours)
void
setChunkingEnabled(boolean chunkingEnabled)
void
setClientDecompressionEnabled(boolean clientDecompressionEnabled)
void
setColoToCurrentVersions(java.util.Map<java.lang.String,java.lang.Integer> coloToCurrentVersions)
void
setCompressionStrategy(CompressionStrategy compressionStrategy)
void
setCurrentVersion(int currentVersion)
void
setDaVinciPushStatusStoreEnabled(boolean daVinciPushStatusStoreEnabled)
void
setEnableStoreReads(boolean enableStoreReads)
void
setEnableStoreWrites(boolean enableStoreWrites)
void
setEtlStoreConfig(ETLStoreConfig etlStoreConfig)
void
setHybridStoreConfig(HybridStoreConfig hybridStoreConfig)
void
setHybridStoreDiskQuotaEnabled(boolean enabled)
void
setHybridStoreOverheadBypass(boolean overheadBypass)
void
setIncrementalPushEnabled(boolean incrementalPushEnabled)
void
setKafkaBrokerUrl(java.lang.String kafkaBrokerUrl)
void
setLargestUsedVersionNumber(int largestUsedVersionNumber)
void
setLatestSuperSetValueSchemaId(int valueSchemaId)
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
setName(java.lang.String name)
void
setNativeReplicationEnabled(boolean nativeReplicationEnabled)
void
setNativeReplicationSourceFabric(java.lang.String nativeReplicationSourceFabric)
void
setNumVersionsToPreserve(int numVersionsToPreserve)
void
setOwner(java.lang.String owner)
void
setPartitionCount(int partitionCount)
void
setPartitionerConfig(PartitionerConfig partitionerConfig)
void
setPushStreamSourceAddress(java.lang.String sourceAddress)
void
setReadComputationEnabled(boolean readComputationEnabled)
void
setReadQuotaInCU(long readQuotaInCU)
void
setReplicationFactor(int replicationFactor)
void
setReplicationMetadataVersionId(int replicationMetadataVersionId)
void
setReservedVersion(int reservedVersion)
void
setRmdChunkingEnabled(boolean rmdChunkingEnabled)
void
setSchemaAutoRegisterFromPushJobEnabled(boolean value)
void
setSingleGetRouterCacheEnabled(boolean singleGetRouterCacheEnabled)
void
setStorageNodeReadQuotaEnabled(boolean storageNodeReadQuotaEnabled)
void
setStorageQuotaInByte(long storageQuotaInByte)
void
setStoreMetadataSystemStoreEnabled(boolean storeMetadataSystemStoreEnabled)
void
setStoreMetaSystemStoreEnabled(boolean storeMetaSystemStoreEnabled)
void
setSuperSetSchemaAutoGenerationForReadComputeEnabled(boolean value)
void
setUnusedSchemaDeletionEnabled(boolean unusedSchemaDeletionEnabled)
void
setVersions(java.util.List<Version> versions)
void
setViewConfigs(java.util.Map<java.lang.String,ViewConfig> viewConfigs)
void
setWriteComputationEnabled(boolean writeComputationEnabled)
-
-
-
Method Detail
-
getName
public java.lang.String getName()
Store Name- Returns:
-
setName
public void setName(java.lang.String name)
-
setKafkaBrokerUrl
public void setKafkaBrokerUrl(java.lang.String kafkaBrokerUrl)
-
getKafkaBrokerUrl
public java.lang.String getKafkaBrokerUrl()
-
getOwner
public java.lang.String getOwner()
Store Owner- Returns:
-
setOwner
public void setOwner(java.lang.String owner)
-
getCurrentVersion
public int getCurrentVersion()
The version of the store which is currently being served- Returns:
-
setCurrentVersion
public void setCurrentVersion(int currentVersion)
-
getColoToCurrentVersions
public java.util.Map<java.lang.String,java.lang.Integer> getColoToCurrentVersions()
-
setColoToCurrentVersions
public void setColoToCurrentVersions(java.util.Map<java.lang.String,java.lang.Integer> coloToCurrentVersions)
-
getReservedVersion
public int getReservedVersion()
The highest version number that has been reserved. Any component that did not reserve a version must create or reserve versions higher than this- Returns:
-
setReservedVersion
public void setReservedVersion(int reservedVersion)
-
getPartitionCount
public int getPartitionCount()
The number of partitions for this store- Returns:
-
setPartitionCount
public void setPartitionCount(int partitionCount)
-
getLowWatermark
public long getLowWatermark()
-
setLowWatermark
public void setLowWatermark(long lowWatermark)
-
isEnableStoreWrites
public boolean isEnableStoreWrites()
Whether the store is enableStoreWrites, a enableStoreWrites store cannot have new versions pushed- Returns:
-
setEnableStoreWrites
public void setEnableStoreWrites(boolean enableStoreWrites)
-
isEnableStoreReads
public boolean isEnableStoreReads()
-
setEnableStoreReads
public void setEnableStoreReads(boolean enableStoreReads)
-
getVersions
public java.util.List<Version> getVersions()
List of available versions for this store- Returns:
-
getVersion
public java.util.Optional<Version> getVersion(int versionNum)
-
setVersions
public void setVersions(java.util.List<Version> versions)
-
getStorageQuotaInByte
public long getStorageQuotaInByte()
-
setStorageQuotaInByte
public void setStorageQuotaInByte(long storageQuotaInByte)
-
getHybridStoreOverheadBypass
public boolean getHybridStoreOverheadBypass()
-
setHybridStoreOverheadBypass
public void setHybridStoreOverheadBypass(boolean overheadBypass)
-
getReadQuotaInCU
public long getReadQuotaInCU()
-
setReadQuotaInCU
public void setReadQuotaInCU(long readQuotaInCU)
-
getHybridStoreConfig
public HybridStoreConfig getHybridStoreConfig()
-
setHybridStoreConfig
public void setHybridStoreConfig(HybridStoreConfig hybridStoreConfig)
-
isAccessControlled
public boolean isAccessControlled()
-
setAccessControlled
public void setAccessControlled(boolean accessControlled)
-
isChunkingEnabled
public boolean isChunkingEnabled()
-
setChunkingEnabled
public void setChunkingEnabled(boolean chunkingEnabled)
-
isRmdChunkingEnabled
public boolean isRmdChunkingEnabled()
-
setRmdChunkingEnabled
public void setRmdChunkingEnabled(boolean rmdChunkingEnabled)
-
isSingleGetRouterCacheEnabled
public boolean isSingleGetRouterCacheEnabled()
-
setSingleGetRouterCacheEnabled
public void setSingleGetRouterCacheEnabled(boolean singleGetRouterCacheEnabled)
-
isBatchGetRouterCacheEnabled
public boolean isBatchGetRouterCacheEnabled()
-
setBatchGetRouterCacheEnabled
public void setBatchGetRouterCacheEnabled(boolean batchGetRouterCacheEnabled)
-
getBatchGetLimit
public int getBatchGetLimit()
-
setBatchGetLimit
public void setBatchGetLimit(int batchGetLimit)
-
getLargestUsedVersionNumber
public int getLargestUsedVersionNumber()
-
setLargestUsedVersionNumber
public void setLargestUsedVersionNumber(int largestUsedVersionNumber)
-
isIncrementalPushEnabled
public boolean isIncrementalPushEnabled()
-
setIncrementalPushEnabled
public void setIncrementalPushEnabled(boolean incrementalPushEnabled)
-
getCompressionStrategy
public CompressionStrategy getCompressionStrategy()
-
setCompressionStrategy
public void setCompressionStrategy(CompressionStrategy compressionStrategy)
-
getClientDecompressionEnabled
public boolean getClientDecompressionEnabled()
-
setClientDecompressionEnabled
public void setClientDecompressionEnabled(boolean clientDecompressionEnabled)
-
getNumVersionsToPreserve
public int getNumVersionsToPreserve()
-
setNumVersionsToPreserve
public void setNumVersionsToPreserve(int numVersionsToPreserve)
-
isMigrating
public boolean isMigrating()
-
setMigrating
public void setMigrating(boolean migrating)
-
isWriteComputationEnabled
public boolean isWriteComputationEnabled()
-
setWriteComputationEnabled
public void setWriteComputationEnabled(boolean writeComputationEnabled)
-
getViewConfigs
public java.util.Map<java.lang.String,ViewConfig> getViewConfigs()
-
setViewConfigs
public void setViewConfigs(java.util.Map<java.lang.String,ViewConfig> viewConfigs)
-
getReplicationMetadataVersionId
public int getReplicationMetadataVersionId()
-
setReplicationMetadataVersionId
public void setReplicationMetadataVersionId(int replicationMetadataVersionId)
-
isReadComputationEnabled
public boolean isReadComputationEnabled()
-
setReadComputationEnabled
public void setReadComputationEnabled(boolean readComputationEnabled)
-
getBootstrapToOnlineTimeoutInHours
public int getBootstrapToOnlineTimeoutInHours()
-
setBootstrapToOnlineTimeoutInHours
public void setBootstrapToOnlineTimeoutInHours(int bootstrapToOnlineTimeoutInHours)
-
setBackupStrategy
public void setBackupStrategy(BackupStrategy value)
-
getBackupStrategy
public BackupStrategy getBackupStrategy()
-
isSchemaAutoRegisterFromPushJobEnabled
public boolean isSchemaAutoRegisterFromPushJobEnabled()
-
setSchemaAutoRegisterFromPushJobEnabled
public void setSchemaAutoRegisterFromPushJobEnabled(boolean value)
-
isSuperSetSchemaAutoGenerationForReadComputeEnabled
public boolean isSuperSetSchemaAutoGenerationForReadComputeEnabled()
-
setSuperSetSchemaAutoGenerationForReadComputeEnabled
public void setSuperSetSchemaAutoGenerationForReadComputeEnabled(boolean value)
-
getPushStreamSourceAddress
public java.lang.String getPushStreamSourceAddress()
-
setPushStreamSourceAddress
public void setPushStreamSourceAddress(java.lang.String sourceAddress)
-
isNativeReplicationEnabled
public boolean isNativeReplicationEnabled()
-
setNativeReplicationEnabled
public void setNativeReplicationEnabled(boolean nativeReplicationEnabled)
-
setLatestSuperSetValueSchemaId
public void setLatestSuperSetValueSchemaId(int valueSchemaId)
-
getLatestSuperSetValueSchemaId
public int getLatestSuperSetValueSchemaId()
-
isHybridStoreDiskQuotaEnabled
public boolean isHybridStoreDiskQuotaEnabled()
-
setHybridStoreDiskQuotaEnabled
public void setHybridStoreDiskQuotaEnabled(boolean enabled)
-
getEtlStoreConfig
public ETLStoreConfig getEtlStoreConfig()
-
setEtlStoreConfig
public void setEtlStoreConfig(ETLStoreConfig etlStoreConfig)
-
getPartitionerConfig
public PartitionerConfig getPartitionerConfig()
-
setPartitionerConfig
public void setPartitionerConfig(PartitionerConfig partitionerConfig)
-
getBackupVersionRetentionMs
public long getBackupVersionRetentionMs()
-
setBackupVersionRetentionMs
public void setBackupVersionRetentionMs(long backupVersionRetentionMs)
-
getReplicationFactor
public int getReplicationFactor()
-
setReplicationFactor
public void setReplicationFactor(int replicationFactor)
-
isMigrationDuplicateStore
public boolean isMigrationDuplicateStore()
-
setMigrationDuplicateStore
public void setMigrationDuplicateStore(boolean migrationDuplicateStore)
-
getNativeReplicationSourceFabric
public java.lang.String getNativeReplicationSourceFabric()
-
setNativeReplicationSourceFabric
public void setNativeReplicationSourceFabric(java.lang.String nativeReplicationSourceFabric)
-
isStoreMetadataSystemStoreEnabled
public boolean isStoreMetadataSystemStoreEnabled()
-
setStoreMetadataSystemStoreEnabled
public void setStoreMetadataSystemStoreEnabled(boolean storeMetadataSystemStoreEnabled)
-
isStoreMetaSystemStoreEnabled
public boolean isStoreMetaSystemStoreEnabled()
-
setStoreMetaSystemStoreEnabled
public void setStoreMetaSystemStoreEnabled(boolean storeMetaSystemStoreEnabled)
-
isDaVinciPushStatusStoreEnabled
public boolean isDaVinciPushStatusStoreEnabled()
-
setDaVinciPushStatusStoreEnabled
public void setDaVinciPushStatusStoreEnabled(boolean daVinciPushStatusStoreEnabled)
-
isActiveActiveReplicationEnabled
public boolean isActiveActiveReplicationEnabled()
-
setActiveActiveReplicationEnabled
public void setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled)
-
isStorageNodeReadQuotaEnabled
public boolean isStorageNodeReadQuotaEnabled()
-
setStorageNodeReadQuotaEnabled
public void setStorageNodeReadQuotaEnabled(boolean storageNodeReadQuotaEnabled)
-
getMinCompactionLagSeconds
public long getMinCompactionLagSeconds()
-
setMinCompactionLagSeconds
public void setMinCompactionLagSeconds(long minCompactionLagSeconds)
-
getMaxCompactionLagSeconds
public long getMaxCompactionLagSeconds()
-
setMaxCompactionLagSeconds
public void setMaxCompactionLagSeconds(long maxCompactionLagSeconds)
-
getMaxRecordSizeBytes
public int getMaxRecordSizeBytes()
-
setMaxRecordSizeBytes
public void setMaxRecordSizeBytes(int maxRecordSizeBytes)
-
getMaxNearlineRecordSizeBytes
public int getMaxNearlineRecordSizeBytes()
-
setMaxNearlineRecordSizeBytes
public void setMaxNearlineRecordSizeBytes(int maxNearlineRecordSizeBytes)
-
setUnusedSchemaDeletionEnabled
public void setUnusedSchemaDeletionEnabled(boolean unusedSchemaDeletionEnabled)
-
isUnusedSchemaDeletionEnabled
public boolean isUnusedSchemaDeletionEnabled()
-
setBlobTransferEnabled
public void setBlobTransferEnabled(boolean blobTransferEnabled)
-
isBlobTransferEnabled
public boolean isBlobTransferEnabled()
-
-