Package com.linkedin.venice.meta
Class StoreInfo
java.lang.Object
com.linkedin.venice.meta.StoreInfo
Json-serializable class for sending store information to the controller client
-
Field Summary
Modifier and TypeFieldDescriptionint
RMD (Replication metadata) version ID on the store-level. -
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic StoreInfo
long
int
int
boolean
int
The version of the store which is currently being servedboolean
boolean
int
int
long
long
int
int
long
getName()
Store Nameint
int
getOwner()
Store Ownerint
The number of partitions for this storelong
int
int
int
The highest version number that has been reserved.long
int
getVersion
(int versionNum) List of available versions for this storeboolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
Whether the store is enableStoreWrites, a enableStoreWrites store cannot have new versions pushedboolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
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
(Map<String, 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
setIsDavinciHeartbeatReported
(boolean isReported) void
setKafkaBrokerUrl
(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
void
setNativeReplicationEnabled
(boolean nativeReplicationEnabled) void
setNativeReplicationSourceFabric
(String nativeReplicationSourceFabric) void
setNearlineProducerCompressionEnabled
(boolean nearlineProducerCompressionEnabled) void
setNearlineProducerCountPerWriter
(int nearlineProducerCountPerWriter) void
setNumVersionsToPreserve
(int numVersionsToPreserve) void
void
setPartitionCount
(int partitionCount) void
setPartitionerConfig
(PartitionerConfig partitionerConfig) void
setPushStreamSourceAddress
(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
setTargetRegionSwap
(String targetRegion) void
setTargetRegionSwapWaitTime
(int waitTime) void
setUnusedSchemaDeletionEnabled
(boolean unusedSchemaDeletionEnabled) void
setVersions
(List<Version> versions) void
setViewConfigs
(Map<String, ViewConfig> viewConfigs) void
setWriteComputationEnabled
(boolean writeComputationEnabled)
-
Field Details
-
replicationMetadataVersionId
public int replicationMetadataVersionIdRMD (Replication metadata) version ID on the store-level. Default is -1.
-
-
Constructor Details
-
StoreInfo
public StoreInfo()
-
-
Method Details
-
fromStore
-
getName
Store Name- Returns:
-
setName
-
setKafkaBrokerUrl
-
getKafkaBrokerUrl
-
getOwner
Store Owner- Returns:
-
setOwner
-
getCurrentVersion
public int getCurrentVersion()The version of the store which is currently being served- Returns:
-
setCurrentVersion
public void setCurrentVersion(int currentVersion) -
getColoToCurrentVersions
-
setColoToCurrentVersions
-
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
List of available versions for this store- Returns:
-
getVersion
-
setVersions
-
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
-
setHybridStoreConfig
-
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
-
setCompressionStrategy
-
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
-
setViewConfigs
-
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
-
getBackupStrategy
-
isSchemaAutoRegisterFromPushJobEnabled
public boolean isSchemaAutoRegisterFromPushJobEnabled() -
setSchemaAutoRegisterFromPushJobEnabled
public void setSchemaAutoRegisterFromPushJobEnabled(boolean value) -
isSuperSetSchemaAutoGenerationForReadComputeEnabled
public boolean isSuperSetSchemaAutoGenerationForReadComputeEnabled() -
setSuperSetSchemaAutoGenerationForReadComputeEnabled
public void setSuperSetSchemaAutoGenerationForReadComputeEnabled(boolean value) -
getPushStreamSourceAddress
-
setPushStreamSourceAddress
-
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
-
setEtlStoreConfig
-
getPartitionerConfig
-
setPartitionerConfig
-
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
-
setNativeReplicationSourceFabric
-
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() -
isNearlineProducerCompressionEnabled
public boolean isNearlineProducerCompressionEnabled() -
setNearlineProducerCompressionEnabled
public void setNearlineProducerCompressionEnabled(boolean nearlineProducerCompressionEnabled) -
getNearlineProducerCountPerWriter
public int getNearlineProducerCountPerWriter() -
setNearlineProducerCountPerWriter
public void setNearlineProducerCountPerWriter(int nearlineProducerCountPerWriter) -
getTargetRegionSwap
-
setTargetRegionSwap
-
getTargetRegionSwapWaitTime
public int getTargetRegionSwapWaitTime() -
setTargetRegionSwapWaitTime
public void setTargetRegionSwapWaitTime(int waitTime) -
setIsDavinciHeartbeatReported
public void setIsDavinciHeartbeatReported(boolean isReported) -
getIsDavinciHeartbeatReported
public boolean getIsDavinciHeartbeatReported()
-