Package org.apache.spark

Class InternalAccumulator.shuffleRead$

Object

org.apache.spark.InternalAccumulator.shuffleRead$

Enclosing class:

InternalAccumulator

public static class InternalAccumulator.shuffleRead$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final InternalAccumulator.shuffleRead$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
shuffleRead$()

Method Summary

Modifier and Type	Method	Description
String	CORRUPT_MERGED_BLOCK_CHUNKS()
String	FETCH_WAIT_TIME()
String	LOCAL_BLOCKS_FETCHED()
String	LOCAL_BYTES_READ()
String	LOCAL_MERGED_BLOCKS_FETCHED()
String	LOCAL_MERGED_BYTES_READ()
String	LOCAL_MERGED_CHUNKS_FETCHED()
String	MERGED_FETCH_FALLBACK_COUNT()
String	RECORDS_READ()
String	REMOTE_BLOCKS_FETCHED()
String	REMOTE_BYTES_READ()
String	REMOTE_BYTES_READ_TO_DISK()
String	REMOTE_MERGED_BLOCKS_FETCHED()
String	REMOTE_MERGED_BYTES_READ()
String	REMOTE_MERGED_CHUNKS_FETCHED()
String	REMOTE_MERGED_REQS_DURATION()
String	REMOTE_REQS_DURATION()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final InternalAccumulator.shuffleRead$ MODULE$

Static reference to the singleton instance of this Scala object.

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