diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-01-01 12:21:32 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-01-01 12:21:32 -0800 |
commit | 02497f0cd49a24ebc8b92d3471de250319fe56cd (patch) | |
tree | 380c9b0f813ae9f01e087919ce2b7ce8a2005187 /streaming/src | |
parent | 18b9b3b99fd753899d19bd10f0dbef7d5c4ae8d7 (diff) | |
download | spark-02497f0cd49a24ebc8b92d3471de250319fe56cd.tar.gz spark-02497f0cd49a24ebc8b92d3471de250319fe56cd.tar.bz2 spark-02497f0cd49a24ebc8b92d3471de250319fe56cd.zip |
Updated Streaming Programming Guide.
Diffstat (limited to 'streaming/src')
-rw-r--r-- | streaming/src/main/scala/spark/streaming/util/RecurringTimer.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/streaming/src/main/scala/spark/streaming/util/RecurringTimer.scala b/streaming/src/main/scala/spark/streaming/util/RecurringTimer.scala index 2e7f4169c9..db715cc295 100644 --- a/streaming/src/main/scala/spark/streaming/util/RecurringTimer.scala +++ b/streaming/src/main/scala/spark/streaming/util/RecurringTimer.scala @@ -54,6 +54,7 @@ class RecurringTimer(val clock: Clock, val period: Long, val callback: (Long) => } } +private[streaming] object RecurringTimer { def main(args: Array[String]) { |