Package org.apache.hadoop.hdfs.client.impl

Class DfsClientConf.ShortCircuitConf

java.lang.Object
org.apache.hadoop.hdfs.client.impl.DfsClientConf.ShortCircuitConf
Enclosing class:
DfsClientConf
public static class DfsClientConf.ShortCircuitConf extends Object
Configuration for short-circuit reads.

  • Constructor Details

    • ShortCircuitConf

      public ShortCircuitConf(org.apache.hadoop.conf.Configuration conf)

  • Method Details

    • getSocketCacheCapacity

      public int getSocketCacheCapacity()
      Returns:
      the socketCacheCapacity

    • getSocketCacheExpiry

      public long getSocketCacheExpiry()
      Returns:
      the socketCacheExpiry

    • isUseLegacyBlockReaderLocal

      public boolean isUseLegacyBlockReaderLocal()

    • getDomainSocketPath

      public String getDomainSocketPath()

    • isShortCircuitLocalReads

      public boolean isShortCircuitLocalReads()

    • isScrMetricsEnabled

      public boolean isScrMetricsEnabled()

    • getScrMetricsSamplingPercentage

      public int getScrMetricsSamplingPercentage()

    • isDomainSocketDataTraffic

      public boolean isDomainSocketDataTraffic()

    • isSkipShortCircuitChecksums

      public boolean isSkipShortCircuitChecksums()
      Returns:
      the skipShortCircuitChecksums

    • getShortCircuitBufferSize

      public int getShortCircuitBufferSize()
      Returns:
      the shortCircuitBufferSize

    • getShortCircuitStreamsCacheSize

      public int getShortCircuitStreamsCacheSize()
      Returns:
      the shortCircuitStreamsCacheSize

    • getShortCircuitStreamsCacheExpiryMs

      public long getShortCircuitStreamsCacheExpiryMs()
      Returns:
      the shortCircuitStreamsCacheExpiryMs

    • getShortCircuitSharedMemoryWatcherInterruptCheckMs

      public int getShortCircuitSharedMemoryWatcherInterruptCheckMs()
      Returns:
      the shortCircuitSharedMemoryWatcherInterruptCheckMs

    • isShortCircuitMmapEnabled

      public boolean isShortCircuitMmapEnabled()
      Returns:
      the shortCircuitMmapEnabled

    • getShortCircuitMmapCacheSize

      public int getShortCircuitMmapCacheSize()
      Returns:
      the shortCircuitMmapCacheSize

    • getShortCircuitMmapCacheExpiryMs

      public long getShortCircuitMmapCacheExpiryMs()
      Returns:
      the shortCircuitMmapCacheExpiryMs

    • getShortCircuitMmapCacheRetryTimeout

      public long getShortCircuitMmapCacheRetryTimeout()
      Returns:
      the shortCircuitMmapCacheRetryTimeout

    • getShortCircuitCacheStaleThresholdMs

      public long getShortCircuitCacheStaleThresholdMs()
      Returns:
      the shortCircuitCacheStaleThresholdMs

    • getDomainSocketDisableIntervalSeconds

      public long getDomainSocketDisableIntervalSeconds()
      Returns:
      the domainSocketDisableIntervalSeconds

    • getKeyProviderCacheExpiryMs

      public long getKeyProviderCacheExpiryMs()
      Returns:
      the keyProviderCacheExpiryMs

    • confAsString

      public String confAsString()