Package com.linkedin.venice.meta

Class SystemStore

  • All Implemented Interfaces:
    Store
    public class SystemStore
extends AbstractStore
    This SystemStore class is a wrapper of the corresponding zk shared system store and the regular venice store to provide the exact same interface as the regular Venice Store for System Stores. For the shared properties across all the same kind of system stores, they will be fetched from the zk shared system store, such as partition count, replication factor and so on. For the non-shared properties, such as current version/versions/largestUsedVersionNumber, they will fetched from the regular venice store. Need to keep in mind that all the shared properties are not mutable here, and if we want to change the shared properties, we need to modify the zk shared store (a regular Venice store) instead of here.

    • Method Detail

      • getZkSharedStore

        public Store getZkSharedStore()

      • getVeniceStore

        public Store getVeniceStore()

      • getName

        public java.lang.String getName()

      • getOwner

        public java.lang.String getOwner()

      • setOwner

        public void setOwner​(java.lang.String owner)

      • getCreatedTime

        public long getCreatedTime()

      • getCurrentVersion

        public int getCurrentVersion()

      • setCurrentVersion

        public void setCurrentVersion​(int currentVersion)

      • setCurrentVersionWithoutCheck

        public void setCurrentVersionWithoutCheck​(int currentVersion)

      • getLowWatermark

        public long getLowWatermark()

      • setLowWatermark

        public void setLowWatermark​(long lowWatermark)

      • setPersistenceType

        public void setPersistenceType​(PersistenceType persistenceType)

      • getLargestUsedVersionNumber

        public int getLargestUsedVersionNumber()

      • setLargestUsedVersionNumber

        public void setLargestUsedVersionNumber​(int largestUsedVersionNumber)

      • getStorageQuotaInByte

        public long getStorageQuotaInByte()

      • setStorageQuotaInByte

        public void setStorageQuotaInByte​(long storageQuotaInByte)

      • getPartitionCount

        public int getPartitionCount()

      • setPartitionCount

        public void setPartitionCount​(int partitionCount)

      • setPartitionerConfig

        public void setPartitionerConfig​(PartitionerConfig value)

      • isEnableWrites

        public boolean isEnableWrites()
        System stores are the internal stores, and even the corresponding user store is not writable, and the internal system stores could be writable, which is controlled by the zkSharedStore.

      • setEnableWrites

        public void setEnableWrites​(boolean enableWrites)

      • isEnableReads

        public boolean isEnableReads()
        System stores are the internal stores, and even the corresponding user store is not readable, and the internal system stores could be readable, which is controlled by the zkSharedStore.

      • setEnableReads

        public void setEnableReads​(boolean enableReads)

      • getReadQuotaInCU

        public long getReadQuotaInCU()

      • setReadQuotaInCU

        public void setReadQuotaInCU​(long readQuotaInCU)

      • setHybridStoreConfig

        public void setHybridStoreConfig​(HybridStoreConfig hybridStoreConfig)

      • getViewConfigs

        public java.util.Map<java.lang.String,​ViewConfig> getViewConfigs()

      • setViewConfigs

        public void setViewConfigs​(java.util.Map<java.lang.String,​ViewConfig> viewConfigList)

      • isHybrid

        public boolean isHybrid()

      • setCompressionStrategy

        public void setCompressionStrategy​(CompressionStrategy compressionStrategy)

      • getClientDecompressionEnabled

        public boolean getClientDecompressionEnabled()

      • setClientDecompressionEnabled

        public void setClientDecompressionEnabled​(boolean clientDecompressionEnabled)

      • isChunkingEnabled

        public boolean isChunkingEnabled()

      • setChunkingEnabled

        public void setChunkingEnabled​(boolean chunkingEnabled)

      • isRmdChunkingEnabled

        public boolean isRmdChunkingEnabled()

      • setRmdChunkingEnabled

        public void setRmdChunkingEnabled​(boolean rmdChunkingEnabled)

      • getBatchGetLimit

        public int getBatchGetLimit()

      • setBatchGetLimit

        public void setBatchGetLimit​(int batchGetLimit)

      • isIncrementalPushEnabled

        public boolean isIncrementalPushEnabled()

      • setIncrementalPushEnabled

        public void setIncrementalPushEnabled​(boolean incrementalPushEnabled)

      • isAccessControlled

        public boolean isAccessControlled()

      • setAccessControlled

        public void setAccessControlled​(boolean accessControlled)

      • isMigrating

        public boolean isMigrating()
        The system store will be migrated together with the corresponding Venice store.
        Returns:

      • setMigrating

        public void setMigrating​(boolean migrating)

      • getNumVersionsToPreserve

        public int getNumVersionsToPreserve()

      • setNumVersionsToPreserve

        public void setNumVersionsToPreserve​(int numVersionsToPreserve)

      • isWriteComputationEnabled

        public boolean isWriteComputationEnabled()

      • setWriteComputationEnabled

        public void setWriteComputationEnabled​(boolean writeComputationEnabled)

      • isReadComputationEnabled

        public boolean isReadComputationEnabled()

      • setReadComputationEnabled

        public void setReadComputationEnabled​(boolean readComputationEnabled)

      • getBootstrapToOnlineTimeoutInHours

        public int getBootstrapToOnlineTimeoutInHours()

      • setBootstrapToOnlineTimeoutInHours

        public void setBootstrapToOnlineTimeoutInHours​(int bootstrapToOnlineTimeoutInHours)

      • getPushStreamSourceAddress

        public java.lang.String getPushStreamSourceAddress()

      • setPushStreamSourceAddress

        public void setPushStreamSourceAddress​(java.lang.String sourceAddress)

      • isNativeReplicationEnabled

        public boolean isNativeReplicationEnabled()

      • getRmdVersion

        public int getRmdVersion()

      • setRmdVersion

        public void setRmdVersion​(int rmdVersion)

      • setNativeReplicationEnabled

        public void setNativeReplicationEnabled​(boolean nativeReplicationEnabled)

      • setBackupStrategy

        public void setBackupStrategy​(BackupStrategy value)

      • isSchemaAutoRegisterFromPushJobEnabled

        public boolean isSchemaAutoRegisterFromPushJobEnabled()

      • setSchemaAutoRegisterFromPushJobEnabled

        public void setSchemaAutoRegisterFromPushJobEnabled​(boolean value)

      • getLatestSuperSetValueSchemaId

        public int getLatestSuperSetValueSchemaId()

      • setLatestSuperSetValueSchemaId

        public void setLatestSuperSetValueSchemaId​(int valueSchemaId)

      • isHybridStoreDiskQuotaEnabled

        public boolean isHybridStoreDiskQuotaEnabled()

      • setHybridStoreDiskQuotaEnabled

        public void setHybridStoreDiskQuotaEnabled​(boolean enabled)

      • setEtlStoreConfig

        public void setEtlStoreConfig​(ETLStoreConfig etlStoreConfig)

      • isStoreMetadataSystemStoreEnabled

        public boolean isStoreMetadataSystemStoreEnabled()

      • setStoreMetadataSystemStoreEnabled

        public void setStoreMetadataSystemStoreEnabled​(boolean storeMetadataSystemStoreEnabled)

      • isStoreMetaSystemStoreEnabled

        public boolean isStoreMetaSystemStoreEnabled()

      • setStoreMetaSystemStoreEnabled

        public void setStoreMetaSystemStoreEnabled​(boolean storeMetaSystemStoreEnabled)

      • getLatestVersionPromoteToCurrentTimestamp

        public long getLatestVersionPromoteToCurrentTimestamp()

      • setLatestVersionPromoteToCurrentTimestamp

        public void setLatestVersionPromoteToCurrentTimestamp​(long latestVersionPromoteToCurrentTimestamp)

      • getBackupVersionRetentionMs

        public long getBackupVersionRetentionMs()

      • setBackupVersionRetentionMs

        public void setBackupVersionRetentionMs​(long backupVersionRetentionMs)

      • getRetentionTime

        public long getRetentionTime()

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

      • isActiveActiveReplicationEnabled

        public boolean isActiveActiveReplicationEnabled()

      • setActiveActiveReplicationEnabled

        public void setActiveActiveReplicationEnabled​(boolean activeActiveReplicationEnabled)

      • setSystemStores

        public void setSystemStores​(java.util.Map<java.lang.String,​SystemStoreAttributes> systemStores)

      • isDaVinciPushStatusStoreEnabled

        public boolean isDaVinciPushStatusStoreEnabled()

      • setDaVinciPushStatusStoreEnabled

        public void setDaVinciPushStatusStoreEnabled​(boolean daVinciPushStatusStoreEnabled)

      • isStorageNodeReadQuotaEnabled

        public boolean isStorageNodeReadQuotaEnabled()

      • setStorageNodeReadQuotaEnabled

        public void setStorageNodeReadQuotaEnabled​(boolean storageNodeReadQuotaEnabled)

      • getMinCompactionLagSeconds

        public long getMinCompactionLagSeconds()

      • setMinCompactionLagSeconds

        public void setMinCompactionLagSeconds​(long minCompactionLagSeconds)

      • setUnusedSchemaDeletionEnabled

        public void setUnusedSchemaDeletionEnabled​(boolean unusedSchemaDeletionEnabled)

      • isUnusedSchemaDeletionEnabled

        public boolean isUnusedSchemaDeletionEnabled()

      • getMaxCompactionLagSeconds

        public long getMaxCompactionLagSeconds()

      • setBlobTransferEnabled

        public void setBlobTransferEnabled​(boolean blobTransferEnabled)

      • isBlobTransferEnabled

        public boolean isBlobTransferEnabled()

      • setMaxCompactionLagSeconds

        public void setMaxCompactionLagSeconds​(long maxCompactionLagSeconds)

      • cloneStore

        public Store cloneStore()

      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object