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 3F85E200BDA for ; Tue, 29 Nov 2016 01:38:37 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 3CAD2160B22; Tue, 29 Nov 2016 00:38:37 +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 86AF6160B0D for ; Tue, 29 Nov 2016 01:38:36 +0100 (CET) Received: (qmail 29774 invoked by uid 500); 29 Nov 2016 00:38:35 -0000 Mailing-List: contact dev-help@apex.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.apache.org Delivered-To: mailing list dev@apex.apache.org Received: (qmail 29751 invoked by uid 99); 29 Nov 2016 00:38:34 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 29 Nov 2016 00:38:34 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 933041AB9F8 for ; Tue, 29 Nov 2016 00:38:34 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -7.019 X-Spam-Level: X-Spam-Status: No, score=-7.019 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id VnkNIZtTSQ8O for ; Tue, 29 Nov 2016 00:38:19 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id E5FB65F30C for ; Tue, 29 Nov 2016 00:38:18 +0000 (UTC) Received: (qmail 29341 invoked by uid 99); 29 Nov 2016 00:38:17 -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; Tue, 29 Nov 2016 00:38:17 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C83A5E0163; Tue, 29 Nov 2016 00:38:17 +0000 (UTC) From: davidyan74 To: dev@apex.incubator.apache.org Reply-To: dev@apex.incubator.apache.org Message-ID: Subject: [GitHub] apex-malhar pull request #516: REVIEW ONLY: Purging time buckets in Windowed... Content-Type: text/plain Date: Tue, 29 Nov 2016 00:38:17 +0000 (UTC) archived-at: Tue, 29 Nov 2016 00:38:37 -0000 GitHub user davidyan74 opened a pull request: https://github.com/apache/apex-malhar/pull/516 REVIEW ONLY: Purging time buckets in WindowedStorage @siyuanh Please review. This is based on the other PR you have #503. I'll add unit test for purging if this looks good. You can merge this pull request into a Git repository by running: $ git pull https://github.com/davidyan74/apex-malhar APEXMALHAR-2345 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/apex-malhar/pull/516.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #516 ---- commit 055cb7b9eeef7be8f9c0ae4ea666112bb5f36612 Author: Siyuan Hua Date: 2016-11-21T06:01:59Z Refactor timebucketassigner to add a single timebucket assigner and change the timebucket metadata from array to map to handle unbounded time buckets commit b9421ab9e573b07db90545788050a7b5ed20fbe6 Author: David Yan Date: 2016-11-17T20:58:34Z APEXMALHAR-2345 purging time buckets in WindowedStorage ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastructure@apache.org or file a JIRA ticket with INFRA. ---