Package org.apache.hadoop.hdfs.server.datanode

Class DNConf

java.lang.Object
org.apache.hadoop.hdfs.server.datanode.DNConf
@Private public class DNConf extends Object
Simple class encapsulating all of the configuration that the DataNode loads at startup time.

  • Constructor Details

    • DNConf

      public DNConf(org.apache.hadoop.conf.Configurable dn)

  • Method Details

    • getConf

      public org.apache.hadoop.conf.Configuration getConf()
      Returns the configuration.
      Returns:
      Configuration the configuration

    • getEncryptDataTransfer

      public boolean getEncryptDataTransfer()
      Returns true if encryption enabled for DataTransferProtocol.
      Returns:
      boolean true if encryption enabled for DataTransferProtocol

    • getEncryptionAlgorithm

      public String getEncryptionAlgorithm()
      Returns encryption algorithm configured for DataTransferProtocol, or null if not configured.
      Returns:
      encryption algorithm configured for DataTransferProtocol

    • getXceiverStopTimeout

      public long getXceiverStopTimeout()

    • getMaxLockedMemory

      public long getMaxLockedMemory()

    • getConnectToDnViaHostname

      public boolean getConnectToDnViaHostname()
      Returns true if connect to datanode via hostname
      Returns:
      boolean true if connect to datanode via hostname

    • getSocketTimeout

      public int getSocketTimeout()
      Returns socket timeout
      Returns:
      int socket timeout

    • getSocketWriteTimeout

      public int getSocketWriteTimeout()
      Returns socket write timeout
      Returns:
      int socket write timeout

    • getEcChecksumSocketTimeout

      public int getEcChecksumSocketTimeout()
      Returns socket timeout for computing the checksum of EC blocks
      Returns:
      int socket timeout

    • getSaslPropsResolver

      public org.apache.hadoop.security.SaslPropertiesResolver getSaslPropsResolver()
      Returns the SaslPropertiesResolver configured for use with DataTransferProtocol, or null if not configured.
      Returns:
      SaslPropertiesResolver configured for use with DataTransferProtocol

    • getTrustedChannelResolver

      public org.apache.hadoop.hdfs.protocol.datatransfer.TrustedChannelResolver getTrustedChannelResolver()
      Returns the TrustedChannelResolver configured for use with DataTransferProtocol, or null if not configured.
      Returns:
      TrustedChannelResolver configured for use with DataTransferProtocol

    • getIgnoreSecurePortsForTesting

      public boolean getIgnoreSecurePortsForTesting()
      Returns true if configuration is set to skip checking for proper port configuration in a secured cluster. This is only intended for use in dev testing.
      Returns:
      true if configured to skip checking secured port configuration

    • getAllowNonLocalLazyPersist

      public boolean getAllowNonLocalLazyPersist()

    • getTransferSocketRecvBufferSize

      public int getTransferSocketRecvBufferSize()

    • getTransferSocketSendBufferSize

      public int getTransferSocketSendBufferSize()

    • getDataTransferServerTcpNoDelay

      public boolean getDataTransferServerTcpNoDelay()

    • getBpReadyTimeout

      public long getBpReadyTimeout()

    • getLifelineIntervalMs

      public long getLifelineIntervalMs()
      Returns the interval in milliseconds between sending lifeline messages.
      Returns:
      interval in milliseconds between sending lifeline messages

    • getVolFailuresTolerated

      public int getVolFailuresTolerated()

    • getVolsConfigured

      public int getVolsConfigured()

    • getSlowIoWarningThresholdMs

      public long getSlowIoWarningThresholdMs()

    • getPmemVolumes

      public String[] getPmemVolumes()

    • getPmemCacheRecoveryEnabled

      public boolean getPmemCacheRecoveryEnabled()

    • getProcessCommandsThresholdMs

      public long getProcessCommandsThresholdMs()

    • getBlockReportInterval

      public long getBlockReportInterval()

    • getCacheReportInterval

      public long getCacheReportInterval()

    • setFileIoProfilingSamplingPercentage

      public void setFileIoProfilingSamplingPercentage(int samplingPercentage)

    • setOutliersReportIntervalMs

      public void setOutliersReportIntervalMs(String reportIntervalMs)

    • setDatanodeSlowIoWarningThresholdMs

      public void setDatanodeSlowIoWarningThresholdMs(long threshold)