Class ZKStore
- All Implemented Interfaces:
DataModelBackedStructure<StoreProperties>,Store
This class is NOT thread safe. Concurrency request to ZKStore instance should be controlled in repository level.
When adding fields to Store Metadata (stored in ZK or metadata system store), you need to modify avro schema in this folder:
venice-common/src/main/resources/avro/StoreMeta/StoreMetaValue
Before we enable the zk shared metadata system schema store auto creation:
ConfigKeys.CONTROLLER_ZK_SHARED_META_SYSTEM_SCHEMA_STORE_AUTO_CREATION_ENABLED,
we could continue to modify v1 schema.
But once this is enabled, we need to evolve the value schema by adding a new version, and DON'T EVER CHANGE
THE EXISTING SCHEMA WITHOUT CAREFUL CONSIDERATION!!!
Also make sure json serialization still works.
So the steps will become the following when you want to add a new field to Store Metadata:
1. Evolve the value schema of metadata system schema mentioned by the above section, and always have a default for the
newly added fields.
2. Add getter/setter methods to Store.
When you want to add a simple field to Store metadata, you just need to create getter/setter for the new field.
When you try to add a method starting with 'get', the default json serialization will do serialization by this
method, which could produce some unexpected serialization result, so if it is not for serialization purpose, please
specify JsonIgnore to ignore the method, whose name is starting with 'get'.
TODO: we need to refactor this class to separate Store operations from Store POJO, which is being used by JSON
TODO: Since metadata keeps increasing, maybe we would like to refactor it to builder pattern.
TODO: In the future, we could consider to use avro json serialization directly to make it simpler.
-
Nested Class Summary
Nested classes/interfaces inherited from class com.linkedin.venice.meta.AbstractStore
AbstractStore.StoreVersionSupplier -
Field Summary
Fields inherited from class com.linkedin.venice.meta.AbstractStore
DEFAULT_READ_QUOTA, DEFAULT_REPLICATION_FACTOR, DEFAULT_STORAGE_QUOTAFields inherited from interface com.linkedin.venice.meta.Store
BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOURS, DEFAULT_BATCH_GET_LIMIT, DEFAULT_RT_RETENTION_TIME, IGNORE_VERSION, NON_EXISTING_VERSION, NUM_VERSION_PRESERVE_NOT_SET, SYSTEM_STORE_FORMAT, SYSTEM_STORE_NAME_PREFIX, UNLIMITED_STORAGE_QUOTA -
Constructor Summary
ConstructorsConstructorDescriptionZKStore(StoreProperties storeProperties) ZKStore(String name, String owner, long createdTimeMs, PersistenceType persistenceType, RoutingStrategy routingStrategy, ReadStrategy readStrategy, OfflinePushStrategy offlinePushStrategy, int replicationFactor) ZKStore(String name, String owner, long createdTime, PersistenceType persistenceType, RoutingStrategy routingStrategy, ReadStrategy readStrategy, OfflinePushStrategy offlinePushStrategy, int currentVersion, long storageQuotaInByte, long readQuotaInCU, HybridStoreConfig hybridStoreConfig, PartitionerConfig partitionerConfig, int replicationFactor) -
Method Summary
Modifier and TypeMethodDescriptionCloned a new store based on current data in this store.Return the backed data model.booleanlongintintbooleanlonglongintbooleanintintintlonglonglongintintlonggetName()intintgetOwner()intlongintlongGet the retention time for the RT Topic.intlongintinthashCode()booleanDeprecated.The store level accessControlled flag is no longer valid to be used to skip ACL checks.booleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanisHybrid()booleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanvoidputSystemStore(VeniceSystemStoreType systemStoreType, SystemStoreAttributes systemStoreAttributes) voidsetAccessControlled(boolean accessControlled) Deprecated.The store level accessControlled flag is no longer valid to be used to skip ACL checks.voidsetActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled) voidsetBackupStrategy(BackupStrategy value) voidsetBackupVersionRetentionMs(long backupVersionRetentionMs) voidsetBatchGetLimit(int batchGetLimit) voidsetBlobTransferEnabled(boolean blobTransferEnabled) voidsetBlobTransferInServerEnabled(String blobTransferServerEnabled) voidsetBootstrapToOnlineTimeoutInHours(int bootstrapToOnlineTimeoutInHours) voidsetChunkingEnabled(boolean chunkingEnabled) voidsetClientDecompressionEnabled(boolean clientDecompressionEnabled) voidsetCompactionEnabled(boolean compactionEnabled) voidsetCompactionThresholdMilliseconds(long compactionThresholdMilliseconds) voidsetCompressionStrategy(CompressionStrategy compressionStrategy) voidsetCurrentVersion(int currentVersion) Set current serving version number of this store.voidsetCurrentVersionWithoutCheck(int currentVersion) voidsetDaVinciPushStatusStoreEnabled(boolean daVinciPushStatusStoreEnabled) voidsetEnableReads(boolean enableReads) voidsetEnableWrites(boolean enableWrites) voidsetEnumSchemaEvolutionAllowed(boolean enumSchemaEvolutionAllowed) voidsetEtlStoreConfig(ETLStoreConfig etlStoreConfig) voidsetGlobalRtDivEnabled(boolean globalRtDivEnabled) voidsetHybridStoreConfig(HybridStoreConfig hybridStoreConfig) voidsetHybridStoreDiskQuotaEnabled(boolean enabled) voidsetIncrementalPushEnabled(boolean incrementalPushEnabled) voidsetIsDavinciHeartbeatReported(boolean isReported) voidsetKeyUrnCompressionEnabled(boolean keyUrnCompressionEnabled) voidsetKeyUrnFields(List<String> keyUrnFields) voidsetLargestUsedRTVersionNumber(int largestUsedRTVersionNumber) voidsetLargestUsedVersionNumber(int largestUsedVersionNumber) voidsetLatestSuperSetValueSchemaId(int valueSchemaId) voidsetLatestVersionPromoteToCurrentTimestamp(long latestVersionPromoteToCurrentTimestamp) voidsetLowWatermark(long lowWatermark) voidsetMaxCompactionLagSeconds(long maxCompactionLagSeconds) voidsetMaxNearlineRecordSizeBytes(int maxNearlineRecordSizeBytes) voidsetMaxRecordSizeBytes(int maxRecordSizeBytes) voidsetMigrating(boolean migrating) voidsetMigrationDuplicateStore(boolean migrationDuplicateStore) voidsetMinCompactionLagSeconds(long minCompactionLagSeconds) voidsetNativeReplicationEnabled(boolean nativeReplicationEnabled) voidsetNativeReplicationSourceFabric(String nativeReplicationSourceFabric) voidsetNearlineProducerCompressionEnabled(boolean compressionEnabled) voidsetNearlineProducerCountPerWriter(int producerCnt) voidsetNumVersionsToPreserve(int numVersionsToPreserve) voidvoidsetPartitionCount(int partitionCount) voidvoidsetPersistenceType(PersistenceType persistenceType) voidsetPushStreamSourceAddress(String sourceAddress) voidsetReadComputationEnabled(boolean readComputationEnabled) voidsetReadQuotaInCU(long readQuotaInCU) voidsetReplicationFactor(int replicationFactor) voidsetRmdChunkingEnabled(boolean rmdChunkingEnabled) voidsetRmdVersion(int rmdVersion) voidsetSchemaAutoRegisterFromPushJobEnabled(boolean value) voidsetSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled) voidsetStorageNodeReadQuotaEnabled(boolean storageNodeReadQuotaEnabled) voidsetStorageQuotaInByte(long storageQuotaInByte) voidsetStoreLifecycleHooks(List<LifecycleHooksRecord> storeLifecycleHooks) voidsetStoreMetadataSystemStoreEnabled(boolean storeMetadataSystemStoreEnabled) voidsetStoreMetaSystemStoreEnabled(boolean storeMetaSystemStoreEnabled) voidsetSystemStores(Map<String, SystemStoreAttributes> systemStores) voidsetTargetSwapRegion(String targetRegion) voidsetTargetSwapRegionWaitTime(int waitTime) voidsetTTLRepushEnabled(boolean ttlRepushEnabled) voidsetUnusedSchemaDeletionEnabled(boolean unusedSchemaDeletionEnabled) voidsetVersions(List<Version> versions) voidsetViewConfigs(Map<String, ViewConfig> viewConfigList) voidsetWriteComputationEnabled(boolean writeComputationEnabled) Methods inherited from class com.linkedin.venice.meta.AbstractStore
addVersion, addVersion, checkDisableStoreWrite, containsVersion, deleteVersion, fixMissingFields, forceAddVersion, getVersion, getVersionOrThrow, getVersions, getVersionStatus, isSystemStore, peekNextVersionNumber, retrieveVersionsToDelete, setupVersionSupplier, updateVersionForDaVinciHeartbeat, updateVersionStatusMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface com.linkedin.venice.meta.Store
getVersionNumbers
-
Constructor Details
-
ZKStore
public ZKStore(String name, String owner, long createdTimeMs, PersistenceType persistenceType, RoutingStrategy routingStrategy, ReadStrategy readStrategy, OfflinePushStrategy offlinePushStrategy, int replicationFactor) -
ZKStore
public ZKStore(String name, String owner, long createdTime, PersistenceType persistenceType, RoutingStrategy routingStrategy, ReadStrategy readStrategy, OfflinePushStrategy offlinePushStrategy, int currentVersion, long storageQuotaInByte, long readQuotaInCU, HybridStoreConfig hybridStoreConfig, PartitionerConfig partitionerConfig, int replicationFactor) -
ZKStore
-
ZKStore
-
-
Method Details
-
dataModel
Description copied from interface:DataModelBackedStructureReturn the backed data model.- Specified by:
dataModelin interfaceDataModelBackedStructure<StoreProperties>- Returns:
-
getName
-
getOwner
-
setOwner
-
getCreatedTime
public long getCreatedTime()- Specified by:
getCreatedTimein interfaceStore
-
getCurrentVersion
public int getCurrentVersion()- Specified by:
getCurrentVersionin interfaceStore
-
setCurrentVersion
public void setCurrentVersion(int currentVersion) Set current serving version number of this store. If store is disabled to write, thrownStoreDisabledException.- Specified by:
setCurrentVersionin interfaceStore
-
setCurrentVersionWithoutCheck
public void setCurrentVersionWithoutCheck(int currentVersion) - Specified by:
setCurrentVersionWithoutCheckin interfaceStore
-
getLowWatermark
public long getLowWatermark()- Specified by:
getLowWatermarkin interfaceStore
-
setLowWatermark
public void setLowWatermark(long lowWatermark) - Specified by:
setLowWatermarkin interfaceStore
-
getPersistenceType
- Specified by:
getPersistenceTypein interfaceStore
-
setPersistenceType
- Specified by:
setPersistenceTypein interfaceStore
-
getRoutingStrategy
- Specified by:
getRoutingStrategyin interfaceStore
-
getReadStrategy
- Specified by:
getReadStrategyin interfaceStore
-
getOffLinePushStrategy
- Specified by:
getOffLinePushStrategyin interfaceStore
-
setVersions
- Specified by:
setVersionsin interfaceStore- Overrides:
setVersionsin classAbstractStore
-
getLargestUsedVersionNumber
public int getLargestUsedVersionNumber()- Specified by:
getLargestUsedVersionNumberin interfaceStore
-
setLargestUsedVersionNumber
public void setLargestUsedVersionNumber(int largestUsedVersionNumber) - Specified by:
setLargestUsedVersionNumberin interfaceStore
-
getLargestUsedRTVersionNumber
public int getLargestUsedRTVersionNumber()- Specified by:
getLargestUsedRTVersionNumberin interfaceStore
-
setLargestUsedRTVersionNumber
public void setLargestUsedRTVersionNumber(int largestUsedRTVersionNumber) - Specified by:
setLargestUsedRTVersionNumberin interfaceStore
-
getStorageQuotaInByte
public long getStorageQuotaInByte()- Specified by:
getStorageQuotaInBytein interfaceStore
-
setStorageQuotaInByte
public void setStorageQuotaInByte(long storageQuotaInByte) - Specified by:
setStorageQuotaInBytein interfaceStore
-
getPartitionCount
public int getPartitionCount()- Specified by:
getPartitionCountin interfaceStore
-
setPartitionCount
public void setPartitionCount(int partitionCount) - Specified by:
setPartitionCountin interfaceStore
-
getPartitionerConfig
- Specified by:
getPartitionerConfigin interfaceStore
-
setPartitionerConfig
- Specified by:
setPartitionerConfigin interfaceStore
-
isEnableWrites
public boolean isEnableWrites()- Specified by:
isEnableWritesin interfaceStore
-
setEnableWrites
public void setEnableWrites(boolean enableWrites) - Specified by:
setEnableWritesin interfaceStore
-
isEnableReads
public boolean isEnableReads()- Specified by:
isEnableReadsin interfaceStore
-
setEnableReads
public void setEnableReads(boolean enableReads) - Specified by:
setEnableReadsin interfaceStore
-
getReadQuotaInCU
public long getReadQuotaInCU()- Specified by:
getReadQuotaInCUin interfaceStore
-
setReadQuotaInCU
public void setReadQuotaInCU(long readQuotaInCU) - Specified by:
setReadQuotaInCUin interfaceStore
-
getHybridStoreConfig
- Specified by:
getHybridStoreConfigin interfaceStore
-
setHybridStoreConfig
- Specified by:
setHybridStoreConfigin interfaceStore
-
getViewConfigs
- Specified by:
getViewConfigsin interfaceStore
-
setViewConfigs
- Specified by:
setViewConfigsin interfaceStore
-
isHybrid
public boolean isHybrid() -
getCompressionStrategy
- Specified by:
getCompressionStrategyin interfaceStore
-
setCompressionStrategy
- Specified by:
setCompressionStrategyin interfaceStore
-
getClientDecompressionEnabled
public boolean getClientDecompressionEnabled()- Specified by:
getClientDecompressionEnabledin interfaceStore
-
setClientDecompressionEnabled
public void setClientDecompressionEnabled(boolean clientDecompressionEnabled) - Specified by:
setClientDecompressionEnabledin interfaceStore
-
isChunkingEnabled
public boolean isChunkingEnabled()- Specified by:
isChunkingEnabledin interfaceStore
-
setChunkingEnabled
public void setChunkingEnabled(boolean chunkingEnabled) - Specified by:
setChunkingEnabledin interfaceStore
-
isRmdChunkingEnabled
public boolean isRmdChunkingEnabled()- Specified by:
isRmdChunkingEnabledin interfaceStore
-
setRmdChunkingEnabled
public void setRmdChunkingEnabled(boolean rmdChunkingEnabled) - Specified by:
setRmdChunkingEnabledin interfaceStore
-
getBatchGetLimit
public int getBatchGetLimit()- Specified by:
getBatchGetLimitin interfaceStore
-
setBatchGetLimit
public void setBatchGetLimit(int batchGetLimit) - Specified by:
setBatchGetLimitin interfaceStore
-
isIncrementalPushEnabled
public boolean isIncrementalPushEnabled()- Specified by:
isIncrementalPushEnabledin interfaceStore
-
setIncrementalPushEnabled
public void setIncrementalPushEnabled(boolean incrementalPushEnabled) - Specified by:
setIncrementalPushEnabledin interfaceStore
-
isSeparateRealTimeTopicEnabled
public boolean isSeparateRealTimeTopicEnabled()- Specified by:
isSeparateRealTimeTopicEnabledin interfaceStore
-
setSeparateRealTimeTopicEnabled
public void setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled) - Specified by:
setSeparateRealTimeTopicEnabledin interfaceStore
-
isAccessControlled
public boolean isAccessControlled()Deprecated.The store level accessControlled flag is no longer valid to be used to skip ACL checks.- Specified by:
isAccessControlledin interfaceStore
-
setAccessControlled
public void setAccessControlled(boolean accessControlled) Deprecated.The store level accessControlled flag is no longer valid to be used to skip ACL checks.- Specified by:
setAccessControlledin interfaceStore
-
isMigrating
public boolean isMigrating()- Specified by:
isMigratingin interfaceStore
-
setMigrating
public void setMigrating(boolean migrating) - Specified by:
setMigratingin interfaceStore
-
getNumVersionsToPreserve
public int getNumVersionsToPreserve()- Specified by:
getNumVersionsToPreservein interfaceStore
-
setNumVersionsToPreserve
public void setNumVersionsToPreserve(int numVersionsToPreserve) - Specified by:
setNumVersionsToPreservein interfaceStore
-
isWriteComputationEnabled
public boolean isWriteComputationEnabled()- Specified by:
isWriteComputationEnabledin interfaceStore
-
setWriteComputationEnabled
public void setWriteComputationEnabled(boolean writeComputationEnabled) - Specified by:
setWriteComputationEnabledin interfaceStore
-
isReadComputationEnabled
public boolean isReadComputationEnabled()- Specified by:
isReadComputationEnabledin interfaceStore
-
setReadComputationEnabled
public void setReadComputationEnabled(boolean readComputationEnabled) - Specified by:
setReadComputationEnabledin interfaceStore
-
getBootstrapToOnlineTimeoutInHours
public int getBootstrapToOnlineTimeoutInHours()- Specified by:
getBootstrapToOnlineTimeoutInHoursin interfaceStore
-
setBootstrapToOnlineTimeoutInHours
public void setBootstrapToOnlineTimeoutInHours(int bootstrapToOnlineTimeoutInHours) - Specified by:
setBootstrapToOnlineTimeoutInHoursin interfaceStore
-
getPushStreamSourceAddress
- Specified by:
getPushStreamSourceAddressin interfaceStore
-
setPushStreamSourceAddress
- Specified by:
setPushStreamSourceAddressin interfaceStore
-
isNativeReplicationEnabled
public boolean isNativeReplicationEnabled()- Specified by:
isNativeReplicationEnabledin interfaceStore
-
getRmdVersion
public int getRmdVersion()- Specified by:
getRmdVersionin interfaceStore
-
setRmdVersion
public void setRmdVersion(int rmdVersion) - Specified by:
setRmdVersionin interfaceStore
-
setNativeReplicationEnabled
public void setNativeReplicationEnabled(boolean nativeReplicationEnabled) - Specified by:
setNativeReplicationEnabledin interfaceStore
-
getBackupStrategy
- Specified by:
getBackupStrategyin interfaceStore
-
setBackupStrategy
- Specified by:
setBackupStrategyin interfaceStore
-
isSchemaAutoRegisterFromPushJobEnabled
public boolean isSchemaAutoRegisterFromPushJobEnabled()- Specified by:
isSchemaAutoRegisterFromPushJobEnabledin interfaceStore
-
setSchemaAutoRegisterFromPushJobEnabled
public void setSchemaAutoRegisterFromPushJobEnabled(boolean value) - Specified by:
setSchemaAutoRegisterFromPushJobEnabledin interfaceStore
-
getLatestSuperSetValueSchemaId
public int getLatestSuperSetValueSchemaId()- Specified by:
getLatestSuperSetValueSchemaIdin interfaceStore
-
setLatestSuperSetValueSchemaId
public void setLatestSuperSetValueSchemaId(int valueSchemaId) - Specified by:
setLatestSuperSetValueSchemaIdin interfaceStore
-
isHybridStoreDiskQuotaEnabled
public boolean isHybridStoreDiskQuotaEnabled()- Specified by:
isHybridStoreDiskQuotaEnabledin interfaceStore
-
setHybridStoreDiskQuotaEnabled
public void setHybridStoreDiskQuotaEnabled(boolean enabled) - Specified by:
setHybridStoreDiskQuotaEnabledin interfaceStore
-
getEtlStoreConfig
- Specified by:
getEtlStoreConfigin interfaceStore
-
setEtlStoreConfig
- Specified by:
setEtlStoreConfigin interfaceStore
-
isStoreMetadataSystemStoreEnabled
public boolean isStoreMetadataSystemStoreEnabled()- Specified by:
isStoreMetadataSystemStoreEnabledin interfaceStore
-
setStoreMetadataSystemStoreEnabled
public void setStoreMetadataSystemStoreEnabled(boolean storeMetadataSystemStoreEnabled) - Specified by:
setStoreMetadataSystemStoreEnabledin interfaceStore
-
isStoreMetaSystemStoreEnabled
public boolean isStoreMetaSystemStoreEnabled()- Specified by:
isStoreMetaSystemStoreEnabledin interfaceStore
-
setStoreMetaSystemStoreEnabled
public void setStoreMetaSystemStoreEnabled(boolean storeMetaSystemStoreEnabled) - Specified by:
setStoreMetaSystemStoreEnabledin interfaceStore
-
getLatestVersionPromoteToCurrentTimestamp
public long getLatestVersionPromoteToCurrentTimestamp()- Specified by:
getLatestVersionPromoteToCurrentTimestampin interfaceStore
-
setLatestVersionPromoteToCurrentTimestamp
public void setLatestVersionPromoteToCurrentTimestamp(long latestVersionPromoteToCurrentTimestamp) - Specified by:
setLatestVersionPromoteToCurrentTimestampin interfaceStore
-
getBackupVersionRetentionMs
public long getBackupVersionRetentionMs()- Specified by:
getBackupVersionRetentionMsin interfaceStore
-
setBackupVersionRetentionMs
public void setBackupVersionRetentionMs(long backupVersionRetentionMs) - Specified by:
setBackupVersionRetentionMsin interfaceStore
-
getRetentionTime
public long getRetentionTime()Get the retention time for the RT Topic. If there exists a HybridStoreConfig, return the retention time from the config file. Otherwise, if write compute is enabled, then return the default retention time.- Specified by:
getRetentionTimein interfaceStore- Returns:
- the retention time for the RT topic, in milliseconds.
-
getReplicationFactor
public int getReplicationFactor()- Specified by:
getReplicationFactorin interfaceStore
-
setReplicationFactor
public void setReplicationFactor(int replicationFactor) - Specified by:
setReplicationFactorin interfaceStore
-
isMigrationDuplicateStore
public boolean isMigrationDuplicateStore()- Specified by:
isMigrationDuplicateStorein interfaceStore
-
setMigrationDuplicateStore
public void setMigrationDuplicateStore(boolean migrationDuplicateStore) - Specified by:
setMigrationDuplicateStorein interfaceStore
-
getNativeReplicationSourceFabric
- Specified by:
getNativeReplicationSourceFabricin interfaceStore
-
setNativeReplicationSourceFabric
- Specified by:
setNativeReplicationSourceFabricin interfaceStore
-
isActiveActiveReplicationEnabled
public boolean isActiveActiveReplicationEnabled()- Specified by:
isActiveActiveReplicationEnabledin interfaceStore
-
setActiveActiveReplicationEnabled
public void setActiveActiveReplicationEnabled(boolean activeActiveReplicationEnabled) - Specified by:
setActiveActiveReplicationEnabledin interfaceStore
-
getSystemStores
- Specified by:
getSystemStoresin interfaceStore
-
setSystemStores
- Specified by:
setSystemStoresin interfaceStore
-
putSystemStore
public void putSystemStore(VeniceSystemStoreType systemStoreType, SystemStoreAttributes systemStoreAttributes) - Specified by:
putSystemStorein interfaceStore
-
isDaVinciPushStatusStoreEnabled
public boolean isDaVinciPushStatusStoreEnabled()- Specified by:
isDaVinciPushStatusStoreEnabledin interfaceStore
-
setDaVinciPushStatusStoreEnabled
public void setDaVinciPushStatusStoreEnabled(boolean daVinciPushStatusStoreEnabled) - Specified by:
setDaVinciPushStatusStoreEnabledin interfaceStore
-
isStorageNodeReadQuotaEnabled
public boolean isStorageNodeReadQuotaEnabled()- Specified by:
isStorageNodeReadQuotaEnabledin interfaceStore
-
setStorageNodeReadQuotaEnabled
public void setStorageNodeReadQuotaEnabled(boolean storageNodeReadQuotaEnabled) - Specified by:
setStorageNodeReadQuotaEnabledin interfaceStore
-
getMinCompactionLagSeconds
public long getMinCompactionLagSeconds()- Specified by:
getMinCompactionLagSecondsin interfaceStore
-
setCompactionEnabled
public void setCompactionEnabled(boolean compactionEnabled) - Specified by:
setCompactionEnabledin interfaceStore
-
isCompactionEnabled
public boolean isCompactionEnabled()- Specified by:
isCompactionEnabledin interfaceStore
-
setCompactionThresholdMilliseconds
public void setCompactionThresholdMilliseconds(long compactionThresholdMilliseconds) - Specified by:
setCompactionThresholdMillisecondsin interfaceStore
-
getCompactionThresholdMilliseconds
public long getCompactionThresholdMilliseconds()- Specified by:
getCompactionThresholdMillisecondsin interfaceStore
-
setMinCompactionLagSeconds
public void setMinCompactionLagSeconds(long minCompactionLagSeconds) - Specified by:
setMinCompactionLagSecondsin interfaceStore
-
getMaxCompactionLagSeconds
public long getMaxCompactionLagSeconds()- Specified by:
getMaxCompactionLagSecondsin interfaceStore
-
setMaxCompactionLagSeconds
public void setMaxCompactionLagSeconds(long maxCompactionLagSeconds) - Specified by:
setMaxCompactionLagSecondsin interfaceStore
-
getMaxRecordSizeBytes
public int getMaxRecordSizeBytes()- Specified by:
getMaxRecordSizeBytesin interfaceStore
-
setMaxRecordSizeBytes
public void setMaxRecordSizeBytes(int maxRecordSizeBytes) - Specified by:
setMaxRecordSizeBytesin interfaceStore
-
getMaxNearlineRecordSizeBytes
public int getMaxNearlineRecordSizeBytes()- Specified by:
getMaxNearlineRecordSizeBytesin interfaceStore
-
setMaxNearlineRecordSizeBytes
public void setMaxNearlineRecordSizeBytes(int maxNearlineRecordSizeBytes) - Specified by:
setMaxNearlineRecordSizeBytesin interfaceStore
-
setUnusedSchemaDeletionEnabled
public void setUnusedSchemaDeletionEnabled(boolean unusedSchemaDeletionEnabled) - Specified by:
setUnusedSchemaDeletionEnabledin interfaceStore
-
isUnusedSchemaDeletionEnabled
public boolean isUnusedSchemaDeletionEnabled()- Specified by:
isUnusedSchemaDeletionEnabledin interfaceStore
-
setBlobTransferEnabled
public void setBlobTransferEnabled(boolean blobTransferEnabled) - Specified by:
setBlobTransferEnabledin interfaceStore
-
isBlobTransferEnabled
public boolean isBlobTransferEnabled()- Specified by:
isBlobTransferEnabledin interfaceStore
-
setBlobTransferInServerEnabled
- Specified by:
setBlobTransferInServerEnabledin interfaceStore
-
getBlobTransferInServerEnabled
- Specified by:
getBlobTransferInServerEnabledin interfaceStore
-
isNearlineProducerCompressionEnabled
public boolean isNearlineProducerCompressionEnabled()- Specified by:
isNearlineProducerCompressionEnabledin interfaceStore
-
setNearlineProducerCompressionEnabled
public void setNearlineProducerCompressionEnabled(boolean compressionEnabled) - Specified by:
setNearlineProducerCompressionEnabledin interfaceStore
-
getNearlineProducerCountPerWriter
public int getNearlineProducerCountPerWriter()- Specified by:
getNearlineProducerCountPerWriterin interfaceStore
-
setNearlineProducerCountPerWriter
public void setNearlineProducerCountPerWriter(int producerCnt) - Specified by:
setNearlineProducerCountPerWriterin interfaceStore
-
getTargetSwapRegionWaitTime
public int getTargetSwapRegionWaitTime()- Specified by:
getTargetSwapRegionWaitTimein interfaceStore
-
getTargetSwapRegion
- Specified by:
getTargetSwapRegionin interfaceStore
-
setTargetSwapRegion
- Specified by:
setTargetSwapRegionin interfaceStore
-
setTargetSwapRegionWaitTime
public void setTargetSwapRegionWaitTime(int waitTime) - Specified by:
setTargetSwapRegionWaitTimein interfaceStore
-
setIsDavinciHeartbeatReported
public void setIsDavinciHeartbeatReported(boolean isReported) - Specified by:
setIsDavinciHeartbeatReportedin interfaceStore
-
getIsDavinciHeartbeatReported
public boolean getIsDavinciHeartbeatReported()- Specified by:
getIsDavinciHeartbeatReportedin interfaceStore
-
setGlobalRtDivEnabled
public void setGlobalRtDivEnabled(boolean globalRtDivEnabled) - Specified by:
setGlobalRtDivEnabledin interfaceStore
-
isTTLRepushEnabled
public boolean isTTLRepushEnabled()- Specified by:
isTTLRepushEnabledin interfaceStore
-
setTTLRepushEnabled
public void setTTLRepushEnabled(boolean ttlRepushEnabled) - Specified by:
setTTLRepushEnabledin interfaceStore
-
isEnumSchemaEvolutionAllowed
public boolean isEnumSchemaEvolutionAllowed()- Specified by:
isEnumSchemaEvolutionAllowedin interfaceStore
-
setEnumSchemaEvolutionAllowed
public void setEnumSchemaEvolutionAllowed(boolean enumSchemaEvolutionAllowed) - Specified by:
setEnumSchemaEvolutionAllowedin interfaceStore
-
getStoreLifecycleHooks
- Specified by:
getStoreLifecycleHooksin interfaceStore
-
setStoreLifecycleHooks
- Specified by:
setStoreLifecycleHooksin interfaceStore
-
setKeyUrnCompressionEnabled
public void setKeyUrnCompressionEnabled(boolean keyUrnCompressionEnabled) - Specified by:
setKeyUrnCompressionEnabledin interfaceStore
-
isKeyUrnCompressionEnabled
public boolean isKeyUrnCompressionEnabled()- Specified by:
isKeyUrnCompressionEnabledin interfaceStore
-
setKeyUrnFields
- Specified by:
setKeyUrnFieldsin interfaceStore
-
getKeyUrnFields
- Specified by:
getKeyUrnFieldsin interfaceStore
-
isGlobalRtDivEnabled
public boolean isGlobalRtDivEnabled()- Specified by:
isGlobalRtDivEnabledin interfaceStore
-
equals
-
hashCode
public int hashCode() -
cloneStore
Cloned a new store based on current data in this store. TODO: once the whole stack (all the users of this class) migrates to use modern avro version (1.7+), we could useGenericData.deepCopy(org.apache.avro.Schema, T)to do clone the internal data model:storeProperties, which will be more convenient.- Specified by:
cloneStorein interfaceStore- Returns:
- cloned store.
-