aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorTathagata Das <tathagata.das1565@gmail.com>2013-01-07 14:37:21 -0800
committerTathagata Das <tathagata.das1565@gmail.com>2013-01-07 14:37:21 -0800
commit237bac36e9dca8828192994dad323b8da1619267 (patch)
treef01be9fa6590b2e1604e4791dc720ccad28e2fea /core
parent1346126485444afc065bf4951c4bedebe5c95ce4 (diff)
downloadspark-237bac36e9dca8828192994dad323b8da1619267.tar.gz
spark-237bac36e9dca8828192994dad323b8da1619267.tar.bz2
spark-237bac36e9dca8828192994dad323b8da1619267.zip
Renamed examples and added documentation.
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/spark/RDDCheckpointData.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/RDDCheckpointData.scala b/core/src/main/scala/spark/RDDCheckpointData.scala
index 7af830940f..e270b6312e 100644
--- a/core/src/main/scala/spark/RDDCheckpointData.scala
+++ b/core/src/main/scala/spark/RDDCheckpointData.scala
@@ -65,7 +65,7 @@ extends Logging with Serializable {
cpRDD = Some(newRDD)
rdd.changeDependencies(newRDD)
cpState = Checkpointed
- RDDCheckpointData.checkpointCompleted()
+ RDDCheckpointData.clearTaskCaches()
logInfo("Done checkpointing RDD " + rdd.id + ", new parent is RDD " + newRDD.id)
}
}
@@ -90,7 +90,7 @@ extends Logging with Serializable {
}
private[spark] object RDDCheckpointData {
- def checkpointCompleted() {
+ def clearTaskCaches() {
ShuffleMapTask.clearCache()
ResultTask.clearCache()
}