Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 605B7200B50 for ; Fri, 29 Jul 2016 19:03:47 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 5EEE0160A79; Fri, 29 Jul 2016 17:03:47 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id A617E160A6E for ; Fri, 29 Jul 2016 19:03:46 +0200 (CEST) Received: (qmail 82135 invoked by uid 500); 29 Jul 2016 17:03:45 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 82126 invoked by uid 99); 29 Jul 2016 17:03:45 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 29 Jul 2016 17:03:45 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 642ABE78B5; Fri, 29 Jul 2016 17:03:45 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: ijuma@apache.org To: commits@kafka.apache.org Message-Id: <6c40d74f0c744c1fada2d3f1d96097ce@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: kafka git commit: MINOR: Replace reference to HoppingWindows in streams.html Date: Fri, 29 Jul 2016 17:03:45 +0000 (UTC) archived-at: Fri, 29 Jul 2016 17:03:47 -0000 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 Reviewers: Eno Thereska , Ismael Juma 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 Authored: Fri Jul 29 17:55:57 2016 +0100 Committer: Ismael Juma 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, 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 joined = source1.leftJoin(source2,