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]) { |