ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[SPARK-8476] [CORE] Setters inc/decDiskBytesSpilled in TaskMetrics should also be private.

Browse source 
This is a follow-up of [SPARK-3288](https://issues.apache.org/jira/browse/SPARK-3288).

Author: Takuya UESHIN <ueshin@happy-camper.st>

Closes #6896 from ueshin/issues/SPARK-8476 and squashes the following commits:

89251d8 [Takuya UESHIN] Make inc/decDiskBytesSpilled in TaskMetrics private[spark].
This commit is contained in:
Takuya UESHIN 2015-06-19 10:48:16 -07:00 committed by Reynold Xin
parent 9baf093014
commit fe08561e2e
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala
View file

@ -94,8 +94,8 @@ class TaskMetrics extends Serializable {
*/
private var _diskBytesSpilled: Long = _
def diskBytesSpilled: Long = _diskBytesSpilled
def incDiskBytesSpilled(value: Long): Unit = _diskBytesSpilled += value
def decDiskBytesSpilled(value: Long): Unit = _diskBytesSpilled -= value
private[spark] def incDiskBytesSpilled(value: Long): Unit = _diskBytesSpilled += value
private[spark] def decDiskBytesSpilled(value: Long): Unit = _diskBytesSpilled -= value
/**
* If this task reads from a HadoopRDD or from persisted data, metrics on how much data was read