diff options
| author | Takuya UESHIN <ueshin@happy-camper.st> | 2015-06-19 10:48:16 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-06-19 10:48:16 -0700 |
| commit | fe08561e2ee13fc8f641db8b6e6c1499bdfd4d29 (patch) | |
| tree | 405b45ac542464b48840582098fb2dbd727f8fe3 | |
| parent | 9baf093014a48c5ec49f747773f4500dafdfa4ec (diff) | |
| download | spark-fe08561e2ee13fc8f641db8b6e6c1499bdfd4d29.tar.gz spark-fe08561e2ee13fc8f641db8b6e6c1499bdfd4d29.tar.bz2 spark-fe08561e2ee13fc8f641db8b6e6c1499bdfd4d29.zip | |
[SPARK-8476] [CORE] Setters inc/decDiskBytesSpilled in TaskMetrics should also be private.
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].
| -rw-r--r-- | core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala b/core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala index 38b61d7242..a3b4561b07 100644 --- a/core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala +++ b/core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala @@ -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 |