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

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