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