Package org.apache.hadoop.ozone.container.common.statemachine

Class DatanodeConfiguration

java.lang.Object
org.apache.hadoop.hdds.conf.ReconfigurableConfig
org.apache.hadoop.ozone.container.common.statemachine.DatanodeConfiguration
public class DatanodeConfiguration extends org.apache.hadoop.hdds.conf.ReconfigurableConfig
Configuration class used for high level datanode configuration parameters.

  • Field Details

    • CONFIG_PREFIX

      public static final String CONFIG_PREFIX
      See Also:

    • HDDS_DATANODE_BLOCK_DELETE_THREAD_MAX

      public static final String HDDS_DATANODE_BLOCK_DELETE_THREAD_MAX
      See Also:

    • DISK_CHECK_FILE_SIZE_KEY

      public static final String DISK_CHECK_FILE_SIZE_KEY
      See Also:

    • DISK_CHECK_IO_TEST_COUNT_KEY

      public static final String DISK_CHECK_IO_TEST_COUNT_KEY
      See Also:

    • DISK_CHECK_IO_FAILURES_TOLERATED_KEY

      public static final String DISK_CHECK_IO_FAILURES_TOLERATED_KEY
      See Also:

    • FAILED_DATA_VOLUMES_TOLERATED_KEY

      public static final String FAILED_DATA_VOLUMES_TOLERATED_KEY
      See Also:

    • FAILED_METADATA_VOLUMES_TOLERATED_KEY

      public static final String FAILED_METADATA_VOLUMES_TOLERATED_KEY
      See Also:

    • FAILED_DB_VOLUMES_TOLERATED_KEY

      public static final String FAILED_DB_VOLUMES_TOLERATED_KEY
      See Also:

    • DISK_CHECK_MIN_GAP_KEY

      public static final String DISK_CHECK_MIN_GAP_KEY
      See Also:

    • DISK_CHECK_TIMEOUT_KEY

      public static final String DISK_CHECK_TIMEOUT_KEY
      See Also:

    • HDDS_DATANODE_VOLUME_MIN_FREE_SPACE

      public static final String HDDS_DATANODE_VOLUME_MIN_FREE_SPACE
      See Also:

    • HDDS_DATANODE_VOLUME_MIN_FREE_SPACE_DEFAULT

      public static final String HDDS_DATANODE_VOLUME_MIN_FREE_SPACE_DEFAULT
      See Also:

    • HDDS_DATANODE_VOLUME_MIN_FREE_SPACE_PERCENT

      public static final String HDDS_DATANODE_VOLUME_MIN_FREE_SPACE_PERCENT
      See Also:

    • HDDS_DATANODE_VOLUME_MIN_FREE_SPACE_PERCENT_DEFAULT

      public static final float HDDS_DATANODE_VOLUME_MIN_FREE_SPACE_PERCENT_DEFAULT
      See Also:

    • WAIT_ON_ALL_FOLLOWERS

      public static final String WAIT_ON_ALL_FOLLOWERS
      See Also:

    • CONTAINER_SCHEMA_V3_ENABLED

      public static final String CONTAINER_SCHEMA_V3_ENABLED
      See Also:

    • CONTAINER_CHECKSUM_LOCK_STRIPES_KEY

      public static final String CONTAINER_CHECKSUM_LOCK_STRIPES_KEY
      See Also:

    • CONTAINER_CLIENT_CACHE_SIZE

      public static final String CONTAINER_CLIENT_CACHE_SIZE
      See Also:

    • CONTAINER_CLIENT_CACHE_STALE_THRESHOLD

      public static final String CONTAINER_CLIENT_CACHE_STALE_THRESHOLD
      See Also:

    • DISK_CHECK_IO_TEST_COUNT_DEFAULT

      public static final int DISK_CHECK_IO_TEST_COUNT_DEFAULT
      See Also:

    • DISK_CHECK_IO_FAILURES_TOLERATED_DEFAULT

      public static final int DISK_CHECK_IO_FAILURES_TOLERATED_DEFAULT
      See Also:

    • DISK_CHECK_FILE_SIZE_DEFAULT

      public static final int DISK_CHECK_FILE_SIZE_DEFAULT
      See Also:

    • ROCKSDB_LOG_MAX_FILE_SIZE_BYTES_KEY

      public static final String ROCKSDB_LOG_MAX_FILE_SIZE_BYTES_KEY
      See Also:

    • ROCKSDB_LOG_MAX_FILE_NUM_KEY

      public static final String ROCKSDB_LOG_MAX_FILE_NUM_KEY
      See Also:

    • ROCKSDB_DELETE_OBSOLETE_FILES_PERIOD_MICRO_SECONDS_KEY

      public static final String ROCKSDB_DELETE_OBSOLETE_FILES_PERIOD_MICRO_SECONDS_KEY
      See Also:

    • OZONE_DATANODE_CHECK_EMPTY_CONTAINER_DIR_ON_DELETE_DEFAULT

      public static final Boolean OZONE_DATANODE_CHECK_EMPTY_CONTAINER_DIR_ON_DELETE_DEFAULT

    • CONTAINER_CHECKSUM_LOCK_STRIPES_DEFAULT

      public static final int CONTAINER_CHECKSUM_LOCK_STRIPES_DEFAULT
      See Also:

    • CONTAINER_CLIENT_CACHE_SIZE_DEFAULT

      public static final int CONTAINER_CLIENT_CACHE_SIZE_DEFAULT
      See Also:

    • CONTAINER_CLIENT_CACHE_STALE_THRESHOLD_MILLISECONDS_DEFAULT

      public static final int CONTAINER_CLIENT_CACHE_STALE_THRESHOLD_MILLISECONDS_DEFAULT
      See Also:

    • BLOCK_DELETE_COMMAND_WORKER_INTERVAL

      public static final String BLOCK_DELETE_COMMAND_WORKER_INTERVAL
      See Also:

    • BLOCK_DELETE_COMMAND_WORKER_INTERVAL_DEFAULT

      public static final Duration BLOCK_DELETE_COMMAND_WORKER_INTERVAL_DEFAULT

  • Constructor Details

    • DatanodeConfiguration

      public DatanodeConfiguration()

  • Method Details

    • validate

      public void validate()

    • getBlockDeletionInterval

      public Duration getBlockDeletionInterval()

    • setBlockDeletionInterval

      public void setBlockDeletionInterval(Duration duration)

    • getRecoveringContainerScrubInterval

      public Duration getRecoveringContainerScrubInterval()

    • setRecoveringContainerScrubInterval

      public void setRecoveringContainerScrubInterval(Duration duration)

    • getBlockDeletionLimit

      public int getBlockDeletionLimit()

    • setBlockDeletionLimit

      public void setBlockDeletionLimit(int limit)

    • getDeleteContainerTimeoutMs

      public long getDeleteContainerTimeoutMs()

    • getBlockDeletingMaxLockHoldingTime

      public Duration getBlockDeletingMaxLockHoldingTime()

    • setBlockDeletingMaxLockHoldingTime

      public void setBlockDeletingMaxLockHoldingTime(Duration maxLockHoldingTime)

    • waitOnAllFollowers

      public boolean waitOnAllFollowers()

    • setWaitOnAllFollowers

      public void setWaitOnAllFollowers(boolean val)

    • getContainerDeleteThreads

      public int getContainerDeleteThreads()

    • setContainerDeleteThreads

      public void setContainerDeleteThreads(int containerDeleteThreads)

    • getContainerCloseThreads

      public int getContainerCloseThreads()

    • setContainerCloseThreads

      public void setContainerCloseThreads(int containerCloseThreads)

    • getMinFreeSpace

      public long getMinFreeSpace(long capacity)

    • getMinFreeSpace

      public long getMinFreeSpace()

    • getMinFreeSpaceRatio

      public float getMinFreeSpaceRatio()

    • getPeriodicDiskCheckIntervalMinutes

      public long getPeriodicDiskCheckIntervalMinutes()

    • setPeriodicDiskCheckIntervalMinutes

      public void setPeriodicDiskCheckIntervalMinutes(long periodicDiskCheckIntervalMinutes)

    • getFailedDataVolumesTolerated

      public int getFailedDataVolumesTolerated()

    • setFailedDataVolumesTolerated

      public void setFailedDataVolumesTolerated(int failedVolumesTolerated)

    • getFailedMetadataVolumesTolerated

      public int getFailedMetadataVolumesTolerated()

    • setFailedMetadataVolumesTolerated

      public void setFailedMetadataVolumesTolerated(int failedVolumesTolerated)

    • getFailedDbVolumesTolerated

      public int getFailedDbVolumesTolerated()

    • setFailedDbVolumesTolerated

      public void setFailedDbVolumesTolerated(int failedVolumesTolerated)

    • getVolumeIOTestCount

      public int getVolumeIOTestCount()

    • setVolumeIOTestCount

      public void setVolumeIOTestCount(int testCount)

    • getVolumeIOFailureTolerance

      public int getVolumeIOFailureTolerance()

    • setVolumeIOFailureTolerance

      public void setVolumeIOFailureTolerance(int failureTolerance)

    • getVolumeHealthCheckFileSize

      public int getVolumeHealthCheckFileSize()

    • getVolumeHealthCheckFileSize

      public void getVolumeHealthCheckFileSize(int fileSizeBytes)

    • getCheckEmptyContainerDir

      public boolean getCheckEmptyContainerDir()

    • getDiskCheckMinGap

      public Duration getDiskCheckMinGap()

    • setDiskCheckMinGap

      public void setDiskCheckMinGap(Duration duration)

    • getDiskCheckTimeout

      public Duration getDiskCheckTimeout()

    • setDiskCheckTimeout

      public void setDiskCheckTimeout(Duration duration)

    • getBlockDeleteThreads

      public int getBlockDeleteThreads()

    • setBlockDeleteThreads

      public void setBlockDeleteThreads(int threads)

    • getBlockDeleteQueueLimit

      public int getBlockDeleteQueueLimit()

    • setBlockDeleteQueueLimit

      public void setBlockDeleteQueueLimit(int queueLimit)

    • getBlockDeleteMaxLockWaitTimeoutMs

      public long getBlockDeleteMaxLockWaitTimeoutMs()

    • getBlockDeleteCommandWorkerInterval

      public Duration getBlockDeleteCommandWorkerInterval()

    • setBlockDeleteCommandWorkerInterval

      public void setBlockDeleteCommandWorkerInterval(Duration blockDeleteCommandWorkerInterval)

    • getCommandQueueLimit

      public int getCommandQueueLimit()

    • setCommandQueueLimit

      public void setCommandQueueLimit(int queueLimit)

    • isChunkDataValidationCheck

      public boolean isChunkDataValidationCheck()

    • setChunkDataValidationCheck

      public void setChunkDataValidationCheck(boolean writeChunkValidationCheck)

    • getNumReadThreadPerVolume

      public int getNumReadThreadPerVolume()

    • setNumReadThreadPerVolume

      public void setNumReadThreadPerVolume(int threads)

    • getContainerSchemaV3Enabled

      public boolean getContainerSchemaV3Enabled()

    • setContainerSchemaV3Enabled

      public void setContainerSchemaV3Enabled(boolean containerSchemaV3Enabled)

    • getContainerSchemaV3KeySeparator

      public String getContainerSchemaV3KeySeparator()

    • setContainerSchemaV3KeySeparator

      public void setContainerSchemaV3KeySeparator(String separator)

    • getRocksdbLogLevel

      public String getRocksdbLogLevel()

    • setRocksdbLogLevel

      public void setRocksdbLogLevel(String level)

    • setRocksdbLogMaxFileNum

      public void setRocksdbLogMaxFileNum(int count)

    • getRocksdbLogMaxFileNum

      public int getRocksdbLogMaxFileNum()

    • setRocksdbLogMaxFileSize

      public void setRocksdbLogMaxFileSize(long size)

    • getRocksdbLogMaxFileSize

      public long getRocksdbLogMaxFileSize()

    • getRocksdbDeleteObsoleteFilesPeriod

      public long getRocksdbDeleteObsoleteFilesPeriod()

    • setRocksdbDeleteObsoleteFilesPeriod

      public void setRocksdbDeleteObsoleteFilesPeriod(long period)

    • setRocksdbMaxOpenFiles

      public void setRocksdbMaxOpenFiles(int count)

    • getRocksdbMaxOpenFiles

      public int getRocksdbMaxOpenFiles()

    • autoCompactionSmallSstFile

      public boolean autoCompactionSmallSstFile()

    • setAutoCompactionSmallSstFile

      public void setAutoCompactionSmallSstFile(boolean auto)

    • getAutoCompactionSmallSstFileSize

      public long getAutoCompactionSmallSstFileSize()

    • setAutoCompactionSmallSstFileSize

      public void setAutoCompactionSmallSstFileSize(long size)

    • getAutoCompactionSmallSstFileNum

      public int getAutoCompactionSmallSstFileNum()

    • setAutoCompactionSmallSstFileNum

      public void setAutoCompactionSmallSstFileNum(int num)

    • getContainerChecksumLockStripes

      public int getContainerChecksumLockStripes()

    • getContainerClientCacheSize

      public int getContainerClientCacheSize()

    • getContainerClientCacheStaleThreshold

      public int getContainerClientCacheStaleThreshold()

    • getAutoCompactionSmallSstFileIntervalMinutes

      public long getAutoCompactionSmallSstFileIntervalMinutes()

    • setAutoCompactionSmallSstFileIntervalMinutes

      public void setAutoCompactionSmallSstFileIntervalMinutes(long autoCompactionSmallSstFileIntervalMinutes)

    • getAutoCompactionSmallSstFileThreads

      public int getAutoCompactionSmallSstFileThreads()

    • setAutoCompactionSmallSstFileThreads

      public void setAutoCompactionSmallSstFileThreads(int autoCompactionSmallSstFileThreads)