Package com.linkedin.venice.meta

Class StoreInfo

java.lang.Object
com.linkedin.venice.meta.StoreInfo
public class StoreInfo extends Object
Json-serializable class for sending store information to the controller client

  • Field Details

    • replicationMetadataVersionId

      public int replicationMetadataVersionId
      RMD (Replication metadata) version ID on the store-level. Default is -1.

  • Constructor Details

    • StoreInfo

      public StoreInfo()

  • Method Details

    • fromStore

      public static StoreInfo fromStore(Store store)

    • getName

      public String getName()
      Store Name
      Returns:

    • setName

      public void setName(String name)

    • setKafkaBrokerUrl

      public void setKafkaBrokerUrl(String kafkaBrokerUrl)

    • getKafkaBrokerUrl

      public String getKafkaBrokerUrl()

    • getOwner

      public String getOwner()
      Store Owner
      Returns:

    • setOwner

      public void setOwner(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 Map<String,Integer> getColoToCurrentVersions()

    • setColoToCurrentVersions

      public void setColoToCurrentVersions(Map<String,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 List<Version> getVersions()
      List of available versions for this store
      Returns:

    • getVersion

      public Optional<Version> getVersion(int versionNum)

    • setVersions

      public void setVersions(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)

    • getLargestUsedRTVersionNumber

      public int getLargestUsedRTVersionNumber()

    • setLargestUsedRTVersionNumber

      public void setLargestUsedRTVersionNumber(int largestUsedRTVersionNumber)

    • 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 Map<String,ViewConfig> getViewConfigs()

    • setViewConfigs

      public void setViewConfigs(Map<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 String getPushStreamSourceAddress()

    • setPushStreamSourceAddress

      public void setPushStreamSourceAddress(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 String getNativeReplicationSourceFabric()

    • setNativeReplicationSourceFabric

      public void setNativeReplicationSourceFabric(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)

    • isCompactionEnabled

      public boolean isCompactionEnabled()

    • setCompactionEnabled

      public void setCompactionEnabled(boolean compactionEnabled)

    • getCompactionThreshold

      public long getCompactionThreshold()

    • setCompactionThreshold

      public void setCompactionThreshold(long compactionThreshold)

    • 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()

    • setBlobTransferInServerEnabled

      public void setBlobTransferInServerEnabled(String blobTransferInServerEnable)

    • getBlobTransferInServerEnabled

      public String getBlobTransferInServerEnabled()

    • isNearlineProducerCompressionEnabled

      public boolean isNearlineProducerCompressionEnabled()

    • setNearlineProducerCompressionEnabled

      public void setNearlineProducerCompressionEnabled(boolean nearlineProducerCompressionEnabled)

    • getNearlineProducerCountPerWriter

      public int getNearlineProducerCountPerWriter()

    • setNearlineProducerCountPerWriter

      public void setNearlineProducerCountPerWriter(int nearlineProducerCountPerWriter)

    • getTargetRegionSwap

      public String getTargetRegionSwap()

    • setTargetRegionSwap

      public void setTargetRegionSwap(String targetRegion)

    • getTargetRegionSwapWaitTime

      public int getTargetRegionSwapWaitTime()

    • setTargetRegionSwapWaitTime

      public void setTargetRegionSwapWaitTime(int waitTime)

    • setIsDavinciHeartbeatReported

      public void setIsDavinciHeartbeatReported(boolean isReported)

    • getIsDavinciHeartbeatReported

      public boolean getIsDavinciHeartbeatReported()

    • setIsStoreDead

      public void setIsStoreDead(boolean isStoreDead)

    • getIsStoreDead

      public boolean getIsStoreDead()

    • setStoreDeadStatusReasons

      public void setStoreDeadStatusReasons(List<String> reasons)

    • getStoreDeadStatusReasons

      public List<String> getStoreDeadStatusReasons()

    • setGlobalRtDivEnabled

      public void setGlobalRtDivEnabled(boolean globalRtDivEnabled)

    • isGlobalRtDivEnabled

      public boolean isGlobalRtDivEnabled()

    • setTTLRepushEnabled

      public void setTTLRepushEnabled(boolean ttlRepushEnabled)

    • isTTLRepushEnabled

      public boolean isTTLRepushEnabled()

    • isEnumSchemaEvolutionAllowed

      public boolean isEnumSchemaEvolutionAllowed()

    • setEnumSchemaEvolutionAllowed

      public void setEnumSchemaEvolutionAllowed(boolean enumSchemaEvolutionAllowed)

    • getStoreLifecycleHooks

      public List<LifecycleHooksRecord> getStoreLifecycleHooks()

    • setStoreLifecycleHooks

      public void setStoreLifecycleHooks(List<LifecycleHooksRecord> storeLifecycleHooks)

    • getLatestVersionPromoteToCurrentTimestamp

      public long getLatestVersionPromoteToCurrentTimestamp()

    • setLatestVersionPromoteToCurrentTimestamp

      public void setLatestVersionPromoteToCurrentTimestamp(long latestVersionPromoteToCurrentTimestamp)

    • isKeyUrnCompressionEnabled

      public boolean isKeyUrnCompressionEnabled()

    • setKeyUrnCompressionEnabled

      public void setKeyUrnCompressionEnabled(boolean keyUrnCompressionEnabled)

    • getKeyUrnFields

      public List<String> getKeyUrnFields()

    • setKeyUrnFields

      public void setKeyUrnFields(List<String> keyUrnFields)