diff options
author | Patrick Wendell <pwendell@gmail.com> | 2013-06-27 13:02:47 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2013-06-27 19:14:28 -0700 |
commit | 362d996c81e2b3275a61df2266372ed470ea4d88 (patch) | |
tree | c018eaa58597b1339a2ad837f933fa652b1fb287 /streaming | |
parent | 92a4c2a5f6946bfae2136c52a22899db196f5799 (diff) | |
download | spark-362d996c81e2b3275a61df2266372ed470ea4d88.tar.gz spark-362d996c81e2b3275a61df2266372ed470ea4d88.tar.bz2 spark-362d996c81e2b3275a61df2266372ed470ea4d88.zip |
Handful of changes based on matei's review
- Avoid exception when no tasks have finished for a stage
- Adding DOCTYPE so css renders properly
- Adding progress slider
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/src/main/scala/spark/streaming/Duration.scala | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/Duration.scala b/streaming/src/main/scala/spark/streaming/Duration.scala index ee26206e24..c2135195d8 100644 --- a/streaming/src/main/scala/spark/streaming/Duration.scala +++ b/streaming/src/main/scala/spark/streaming/Duration.scala @@ -1,5 +1,7 @@ package spark.streaming +import spark.Utils + case class Duration (private val millis: Long) { def < (that: Duration): Boolean = (this.millis < that.millis) @@ -32,8 +34,10 @@ case class Duration (private val millis: Long) { def toFormattedString: String = millis.toString def milliseconds: Long = millis -} + def prettyPrint = Utils.msDurationToString(millis) + +} /** * Helper object that creates instance of [[spark.streaming.Duration]] representing |