You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2014/04/17 03:08:13 UTC
git commit: Update ReducedWindowedDStream.scala
Repository: spark
Updated Branches:
refs/heads/master 9c40b9ead -> 07b7ad308
Update ReducedWindowedDStream.scala
change _slideDuration to _windowDuration
Author: baishuo(白硕) <vc...@hotmail.com>
Closes #425 from baishuo/master and squashes the following commits:
6f09ea1 [baishuo(白硕)] Update ReducedWindowedDStream.scala
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/07b7ad30
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/07b7ad30
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/07b7ad30
Branch: refs/heads/master
Commit: 07b7ad30808ea73a375be8a86e96199d704d1422
Parents: 9c40b9e
Author: baishuo(白硕) <vc...@hotmail.com>
Authored: Wed Apr 16 18:08:11 2014 -0700
Committer: Reynold Xin <rx...@apache.org>
Committed: Wed Apr 16 18:08:11 2014 -0700
----------------------------------------------------------------------
.../apache/spark/streaming/dstream/ReducedWindowedDStream.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/07b7ad30/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala
----------------------------------------------------------------------
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 b334d68..40da313 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 + ")"
)