Class InternalAccumulator.shuffleRead$

Object
org.apache.spark.InternalAccumulator.shuffleRead$
Enclosing class:
InternalAccumulator

public static class InternalAccumulator.shuffleRead$ extends Object
  • Field Details

  • Constructor Details

    • shuffleRead$

      public shuffleRead$()
  • Method Details

    • REMOTE_BLOCKS_FETCHED

      public String REMOTE_BLOCKS_FETCHED()
    • LOCAL_BLOCKS_FETCHED

      public String LOCAL_BLOCKS_FETCHED()
    • REMOTE_BYTES_READ

      public String REMOTE_BYTES_READ()
    • REMOTE_BYTES_READ_TO_DISK

      public String REMOTE_BYTES_READ_TO_DISK()
    • LOCAL_BYTES_READ

      public String LOCAL_BYTES_READ()
    • FETCH_WAIT_TIME

      public String FETCH_WAIT_TIME()
    • RECORDS_READ

      public String RECORDS_READ()
    • REMOTE_REQS_DURATION

      public String REMOTE_REQS_DURATION()
    • CORRUPT_MERGED_BLOCK_CHUNKS

      public String CORRUPT_MERGED_BLOCK_CHUNKS()
    • MERGED_FETCH_FALLBACK_COUNT

      public String MERGED_FETCH_FALLBACK_COUNT()
    • REMOTE_MERGED_BLOCKS_FETCHED

      public String REMOTE_MERGED_BLOCKS_FETCHED()
    • LOCAL_MERGED_BLOCKS_FETCHED

      public String LOCAL_MERGED_BLOCKS_FETCHED()
    • REMOTE_MERGED_CHUNKS_FETCHED

      public String REMOTE_MERGED_CHUNKS_FETCHED()
    • LOCAL_MERGED_CHUNKS_FETCHED

      public String LOCAL_MERGED_CHUNKS_FETCHED()
    • REMOTE_MERGED_BYTES_READ

      public String REMOTE_MERGED_BYTES_READ()
    • LOCAL_MERGED_BYTES_READ

      public String LOCAL_MERGED_BYTES_READ()
    • REMOTE_MERGED_REQS_DURATION

      public String REMOTE_MERGED_REQS_DURATION()