kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Replace reference to HoppingWindows in streams.html
Date Fri, 29 Jul 2016 17:03:45 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 ad1dab9c3 -> ab242337a


MINOR: Replace reference to HoppingWindows in streams.html

HoppingWindows was removed prior to the 0.10.0 release. I've updated the doc to refer to the
correct TimeWindows

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Eno Thereska <eno.thereska@gmail.com>, Ismael Juma <ismael@juma.me.uk>

Closes #1679 from dguy/0.10.0


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ab242337
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ab242337
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ab242337

Branch: refs/heads/0.10.0
Commit: ab242337a8fa6fedf632edfc47cb9425a51d8bf3
Parents: ad1dab9
Author: Damian Guy <damian.guy@gmail.com>
Authored: Fri Jul 29 17:55:57 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri Jul 29 17:55:57 2016 +0100

----------------------------------------------------------------------
 docs/streams.html | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ab242337/docs/streams.html
----------------------------------------------------------------------
diff --git a/docs/streams.html b/docs/streams.html
index 91fda36..8231975 100644
--- a/docs/streams.html
+++ b/docs/streams.html
@@ -301,7 +301,7 @@ based on them.
     KTable<Windowed<String>, Long> counts = source1.aggregateByKey(
         () -> 0L,  // initial value
         (aggKey, value, aggregate) -> aggregate + 1L,   // aggregating value
-        HoppingWindows.of("counts").with(5000L).every(1000L), // intervals in milliseconds
+        TimeWindows.of("counts",5000L).advanceBy(1000L), // intervals in milliseconds
     );
 
     KStream<String, String> joined = source1.leftJoin(source2,


Mime
View raw message