aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorTathagata Das <tathagata.das1565@gmail.com>2014-01-10 05:06:15 -0800
committerTathagata Das <tathagata.das1565@gmail.com>2014-01-10 05:06:15 -0800
commit740730a17901f914d0e9d470b8f40e30be33a9bb (patch)
tree2785b33228ffd96b4d87dae491d34d20ccd3856a /core
parent38d75e18fa48bd230e2ff9478e87274fb0cceb9f (diff)
downloadspark-740730a17901f914d0e9d470b8f40e30be33a9bb.tar.gz
spark-740730a17901f914d0e9d470b8f40e30be33a9bb.tar.bz2
spark-740730a17901f914d0e9d470b8f40e30be33a9bb.zip
Fixed conf/slaves and updated docs.
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/util/TimeStampedHashMap.scala9
1 files changed, 6 insertions, 3 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/TimeStampedHashMap.scala b/core/src/main/scala/org/apache/spark/util/TimeStampedHashMap.scala
index 9ce4ef744e..dde504fc52 100644
--- a/core/src/main/scala/org/apache/spark/util/TimeStampedHashMap.scala
+++ b/core/src/main/scala/org/apache/spark/util/TimeStampedHashMap.scala
@@ -26,9 +26,12 @@ import org.apache.spark.Logging
/**
* This is a custom implementation of scala.collection.mutable.Map which stores the insertion
- * time stamp along with each key-value pair. Key-value pairs that are older than a particular
- * threshold time can them be removed using the clearOldValues method. This is intended to be a drop-in
- * replacement of scala.collection.mutable.HashMap.
+ * timestamp along with each key-value pair. If specified, the timestamp of each pair can be
+ * updated every it is accessed. Key-value pairs whose timestamp are older than a particular
+ * threshold time can them be removed using the clearOldValues method. This is intended to
+ * be a drop-in replacement of scala.collection.mutable.HashMap.
+ * @param updateTimeStampOnGet When enabled, the timestamp of a pair will be
+ * updated when it is accessed
*/
class TimeStampedHashMap[A, B](updateTimeStampOnGet: Boolean = false)
extends Map[A, B]() with Logging {