Package com.linkedin.venice.meta

Class StoreInfo

  • public class StoreInfo
extends java.lang.Object
    Json-serializable class for sending store information to the controller client

    • Field Detail

      • replicationMetadataVersionId

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

    • Constructor Detail

      • StoreInfo

        public StoreInfo()

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

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

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

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

      • setEtlStoreConfig

        public void setEtlStoreConfig​(ETLStoreConfig etlStoreConfig)

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

      • isNearlineProducerCompressionEnabled

        public boolean isNearlineProducerCompressionEnabled()

      • setNearlineProducerCompressionEnabled

        public void setNearlineProducerCompressionEnabled​(boolean nearlineProducerCompressionEnabled)

      • getNearlineProducerCountPerWriter

        public int getNearlineProducerCountPerWriter()

      • setNearlineProducerCountPerWriter

        public void setNearlineProducerCountPerWriter​(int nearlineProducerCountPerWriter)