Skip to content

Commit 89251d8

Browse files
committed
Make inc/decDiskBytesSpilled in TaskMetrics private[spark].
1 parent 3eaed87 commit 89251d8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,8 +94,8 @@ class TaskMetrics extends Serializable {
9494
*/
9595
private var _diskBytesSpilled: Long = _
9696
def diskBytesSpilled: Long = _diskBytesSpilled
97-
def incDiskBytesSpilled(value: Long): Unit = _diskBytesSpilled += value
98-
def decDiskBytesSpilled(value: Long): Unit = _diskBytesSpilled -= value
97+
private[spark] def incDiskBytesSpilled(value: Long): Unit = _diskBytesSpilled += value
98+
private[spark] def decDiskBytesSpilled(value: Long): Unit = _diskBytesSpilled -= value
9999

100100
/**
101101
* If this task reads from a HadoopRDD or from persisted data, metrics on how much data was read

0 commit comments

Comments
 (0)