Return-Path: X-Original-To: apmail-apex-dev-archive@minotaur.apache.org Delivered-To: apmail-apex-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E348118AEA for ; Mon, 14 Dec 2015 17:46:49 +0000 (UTC) Received: (qmail 18863 invoked by uid 500); 14 Dec 2015 17:46:49 -0000 Delivered-To: apmail-apex-dev-archive@apex.apache.org Received: (qmail 18804 invoked by uid 500); 14 Dec 2015 17:46:49 -0000 Mailing-List: contact dev-help@apex.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.incubator.apache.org Delivered-To: mailing list dev@apex.incubator.apache.org Received: (qmail 18778 invoked by uid 99); 14 Dec 2015 17:46:49 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 14 Dec 2015 17:46:49 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id F1DB0C0D16 for ; Mon, 14 Dec 2015 17:46:48 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.98 X-Spam-Level: ** X-Spam-Status: No, score=2.98 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=datatorrent-com.20150623.gappssmtp.com Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id veWneu6RkzEI for ; Mon, 14 Dec 2015 17:46:43 +0000 (UTC) Received: from mail-lf0-f42.google.com (mail-lf0-f42.google.com [209.85.215.42]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id C0AEB429C5 for ; Mon, 14 Dec 2015 17:46:42 +0000 (UTC) Received: by lfap203 with SMTP id p203so58340988lfa.0 for ; Mon, 14 Dec 2015 09:46:41 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=datatorrent-com.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=ac6hVa3Ead+7d9VyHwH3XDuyaF3BAnb11CbowpaJL5E=; b=VQUfcDCsXdU5yhAzcl23QOfxOtvKzqaC5FcKCQzZoQ5aDVA+qpAVmAV5leCm9ozc+L Fbpp/nI0f5gI6RcwUBhyuxLU7ZNBFKTsDqymlZnjoIcgqDG4sY+9dwzrKxmeFdYt4vOJ 36ZpIu1crt4rt/NisCrIxiYa2mRZTLNnim4axW0/iQFK/dePswjYhsMOZCYX42Gmn9Yg jM41kSLd+WBTnCi71TD1N3jz6UPLFQGXDdL2fcGDPxj1/N1xJgrkwBeQDxunCNTl1yRw 7b5h1lzhyirYjkDIq0NnX3RSEOnCpDtNi8HkMD4zIJUtZSTbEotfdehOmAN+wErwCpAr JG5g== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:date :message-id:subject:from:to:content-type; bh=ac6hVa3Ead+7d9VyHwH3XDuyaF3BAnb11CbowpaJL5E=; b=mQqH/TOODyf8s+xwQicHx0JFRacSdxl6LKdVzdjDsJi9bNQ9WVrPkEKC/TavQ6dTgS hT/g+hy7ruv9ZDgan+CDRoxKOdnPc/tv1NBwjf9nHDlt0yL7nbxjPNk9KeyRvz75G0a+ 7mS21U0ylq2kga/HOXl7NK175glUrw7TeolR1SDpOPAo8x5/Z7IP4r7LVubV3++CJHph HX3Bbl9ZsHUtYolsK1uAHF6COS30Frphqyf5yucN0YamsznmIgrieMvq3kYF1OW7rZ7J 8IZxCoJHnLB6vo0E3HhGSwJ/+OTMoJ3Bkyi+4niipdUW5nHTYfP5Bnrd5yzkWiwU5yJe OZiQ== X-Gm-Message-State: ALoCoQnc5/m6OCZv3fRr+/SImYIkjB09yx0TejSjhFgBSvuyjeyp5EONCpKCEM2uAPmQxTxF+JNCY+0rIML2pVlULgCIQK7t9/lQfj5CZIKP5Xx6MKK20Nc= MIME-Version: 1.0 X-Received: by 10.25.136.193 with SMTP id k184mr13698454lfd.88.1450115201320; Mon, 14 Dec 2015 09:46:41 -0800 (PST) Received: by 10.25.21.68 with HTTP; Mon, 14 Dec 2015 09:46:41 -0800 (PST) Received: by 10.25.21.68 with HTTP; Mon, 14 Dec 2015 09:46:41 -0800 (PST) In-Reply-To: References: Date: Mon, 14 Dec 2015 09:46:41 -0800 Message-ID: Subject: Re: Operator Utility To Convert Time Into Number Of Windows From: David Yan To: dev@apex.incubator.apache.org Content-Type: multipart/alternative; boundary=001a113fc1107565130526df41c2 --001a113fc1107565130526df41c2 Content-Type: text/plain; charset=UTF-8 Similar utilities are already in WindowGenerator in apex core. Maybe add to that class instead of creating a separate class? David On Dec 11, 2015 4:13 PM, "Timothy Farkas" wrote: > I'd like to propose creating an operator utility in > com.datatorrent.lib.operatorutils to convert time into number of windows > and tuples / second into tuples / window. The way in which this currently > can be specified is through a property like operationWindowCount or > tuplesPerWindow. This works but I've observed that this can lead to > confusion. The confusion comes from the fact that the people who develop > apps are not necessarily the ones who test deployment configurations and > manage the apps, so they think in time not application windows. Also the > default application window count and streaming window size is not common > knowledge, so it's not easy to compute the conversion from windows to time. > This small utility method could be reused across operators. > > Any feedback? > > Thanks, > Tim > --001a113fc1107565130526df41c2--