diff options
| author | baishuo(白硕) <vc_java@hotmail.com> | 2014-04-16 18:08:11 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-04-16 18:08:11 -0700 |
| commit | 07b7ad30808ea73a375be8a86e96199d704d1422 (patch) | |
| tree | f51bcd4d9a97920bf547d65a5aac0d8ee910ad93 /streaming | |
| parent | 9c40b9ead0d17ad836b3507c701198645c33d878 (diff) | |
| download | spark-07b7ad30808ea73a375be8a86e96199d704d1422.tar.gz spark-07b7ad30808ea73a375be8a86e96199d704d1422.tar.bz2 spark-07b7ad30808ea73a375be8a86e96199d704d1422.zip | |
Update ReducedWindowedDStream.scala
change _slideDuration to _windowDuration
Author: baishuo(白硕) <vc_java@hotmail.com>
Closes #425 from baishuo/master and squashes the following commits:
6f09ea1 [baishuo(白硕)] Update ReducedWindowedDStream.scala
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala index b334d68bf9..40da313189 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala @@ -43,7 +43,7 @@ class ReducedWindowedDStream[K: ClassTag, V: ClassTag]( ) extends DStream[(K,V)](parent.ssc) { assert(_windowDuration.isMultipleOf(parent.slideDuration), - "The window duration of ReducedWindowedDStream (" + _slideDuration + ") " + + "The window duration of ReducedWindowedDStream (" + _windowDuration + ") " + "must be multiple of the slide duration of parent DStream (" + parent.slideDuration + ")" ) |