Package com.linkedin.venice.meta

Class SystemStore

java.lang.Object
com.linkedin.venice.meta.AbstractStore
com.linkedin.venice.meta.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.

  • Constructor Details

  • Method Details

    • getZkSharedStore

      public Store getZkSharedStore()

    • getSystemStoreType

      public VeniceSystemStoreType getSystemStoreType()

    • getSerializableSystemStore

      public SerializableSystemStore getSerializableSystemStore()

    • getVeniceStore

      public Store getVeniceStore()

    • getName

      public String getName()

    • getOwner

      public String getOwner()

    • setOwner

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

    • getPersistenceType

      public PersistenceType getPersistenceType()

    • setPersistenceType

      public void setPersistenceType(PersistenceType persistenceType)

    • getRoutingStrategy

      public RoutingStrategy getRoutingStrategy()

    • getReadStrategy

      public ReadStrategy getReadStrategy()

    • getOffLinePushStrategy

      public OfflinePushStrategy getOffLinePushStrategy()

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

    • getPartitionerConfig

      public PartitionerConfig getPartitionerConfig()

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

    • getHybridStoreConfig

      public HybridStoreConfig getHybridStoreConfig()

    • setHybridStoreConfig

      public void setHybridStoreConfig(HybridStoreConfig hybridStoreConfig)

    • getViewConfigs

      public Map<String,ViewConfig> getViewConfigs()

    • setViewConfigs

      public void setViewConfigs(Map<String,ViewConfig> viewConfigList)

    • isHybrid

      public boolean isHybrid()

    • getCompressionStrategy

      public CompressionStrategy getCompressionStrategy()

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

    • isSeparateRealTimeTopicEnabled

      public boolean isSeparateRealTimeTopicEnabled()

    • setSeparateRealTimeTopicEnabled

      public void setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled)

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

    • setPushStreamSourceAddress

      public void setPushStreamSourceAddress(String sourceAddress)

    • isNativeReplicationEnabled

      public boolean isNativeReplicationEnabled()

    • getRmdVersion

      public int getRmdVersion()

    • setRmdVersion

      public void setRmdVersion(int rmdVersion)

    • setNativeReplicationEnabled

      public void setNativeReplicationEnabled(boolean nativeReplicationEnabled)

    • getBackupStrategy

      public BackupStrategy getBackupStrategy()

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

    • getEtlStoreConfig

      public ETLStoreConfig getEtlStoreConfig()

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

    • setNativeReplicationSourceFabric

      public void setNativeReplicationSourceFabric(String nativeReplicationSourceFabric)

    • isActiveActiveReplicationEnabled

      public boolean isActiveActiveReplicationEnabled()

    • setActiveActiveReplicationEnabled

      public void setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled)

    • getSystemStores

      public Map<String,SystemStoreAttributes> getSystemStores()

    • setSystemStores

      public void setSystemStores(Map<String,SystemStoreAttributes> systemStores)

    • putSystemStore

      public void putSystemStore(VeniceSystemStoreType systemStoreType, SystemStoreAttributes systemStoreAttributes)

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

    • getMaxRecordSizeBytes

      public int getMaxRecordSizeBytes()

    • setMaxRecordSizeBytes

      public void setMaxRecordSizeBytes(int maxRecordSizeBytes)

    • getMaxNearlineRecordSizeBytes

      public int getMaxNearlineRecordSizeBytes()

    • setMaxNearlineRecordSizeBytes

      public void setMaxNearlineRecordSizeBytes(int maxNearlineRecordSizeBytes)

    • isNearlineProducerCompressionEnabled

      public boolean isNearlineProducerCompressionEnabled()

    • setNearlineProducerCompressionEnabled

      public void setNearlineProducerCompressionEnabled(boolean compressionEnabled)

    • getNearlineProducerCountPerWriter

      public int getNearlineProducerCountPerWriter()

    • setNearlineProducerCountPerWriter

      public void setNearlineProducerCountPerWriter(int producerCnt)

    • getTargetSwapRegionWaitTime

      public int getTargetSwapRegionWaitTime()

    • getTargetSwapRegion

      public String getTargetSwapRegion()

    • setTargetSwapRegion

      public void setTargetSwapRegion(String targetRegion)

    • setTargetSwapRegionWaitTime

      public void setTargetSwapRegionWaitTime(int waitTime)

    • setIsDavinciHeartbeatReported

      public void setIsDavinciHeartbeatReported(boolean isReported)

    • getIsDavinciHeartbeatReported

      public boolean getIsDavinciHeartbeatReported()

    • cloneStore

      public Store cloneStore()

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object