diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-01-13 21:25:57 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-01-13 21:25:57 -0800 |
| commit | f90f794cde479f4de425e9be0158a136a57666a2 (patch) | |
| tree | cfffefc29395303eedc453079f40fa25495a8f15 /streaming | |
| parent | 6cc8592f26553525e11213830b596fc397243439 (diff) | |
| download | spark-f90f794cde479f4de425e9be0158a136a57666a2.tar.gz spark-f90f794cde479f4de425e9be0158a136a57666a2.tar.bz2 spark-f90f794cde479f4de425e9be0158a136a57666a2.zip | |
Minor name fix
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/DStream.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/streaming/src/main/scala/spark/streaming/DStream.scala b/streaming/src/main/scala/spark/streaming/DStream.scala index d94548a4f3..fbe3cebd6d 100644 --- a/streaming/src/main/scala/spark/streaming/DStream.scala +++ b/streaming/src/main/scala/spark/streaming/DStream.scala @@ -547,10 +547,10 @@ abstract class DStream[T: ClassManifest] ( /** * Returns a new DStream which computed based on tumbling window on this DStream. * This is equivalent to window(batchTime, batchTime). - * @param batchTime tumbling window duration; must be a multiple of this DStream's + * @param batchDuration tumbling window duration; must be a multiple of this DStream's * batching interval */ - def tumble(batchTime: Duration): DStream[T] = window(batchTime, batchTime) + def tumble(batchDuration: Duration): DStream[T] = window(batchDuration, batchDuration) /** * Returns a new DStream in which each RDD has a single element generated by reducing all |