Return-Path: X-Original-To: apmail-beam-dev-archive@minotaur.apache.org Delivered-To: apmail-beam-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 B912D18642 for ; Wed, 23 Mar 2016 20:56:57 +0000 (UTC) Received: (qmail 82058 invoked by uid 500); 23 Mar 2016 20:56:57 -0000 Delivered-To: apmail-beam-dev-archive@beam.apache.org Received: (qmail 81993 invoked by uid 500); 23 Mar 2016 20:56:57 -0000 Mailing-List: contact dev-help@beam.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.incubator.apache.org Delivered-To: mailing list dev@beam.incubator.apache.org Received: (qmail 81981 invoked by uid 99); 23 Mar 2016 20:56:57 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 23 Mar 2016 20:56:57 +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 D3846C0217 for ; Wed, 23 Mar 2016 20:56:56 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.197 X-Spam-Level: * X-Spam-Status: No, score=1.197 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H2=-0.001, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=google.com Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id mtCtgup1DYS6 for ; Wed, 23 Mar 2016 20:56:54 +0000 (UTC) Received: from mail-oi0-f48.google.com (mail-oi0-f48.google.com [209.85.218.48]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with ESMTPS id 0040F5FB39 for ; Wed, 23 Mar 2016 20:56:53 +0000 (UTC) Received: by mail-oi0-f48.google.com with SMTP id r187so36688660oih.3 for ; Wed, 23 Mar 2016 13:56:53 -0700 (PDT) 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:from:date :message-id:subject:to; bh=iUwncZP8qf5DObEmS2OjkRwnpe5bOFQobzgMujqZZ1g=; b=g+ROFhFKgIq6zmUXb8RotuzCrJjpFTjflu5VdQXmdh9Dm2BVlrnDth247vFIUtCago foTHw0/ay6d26icv5JNE+wmwBkUTkEYSoA9BVLIkm37Z9ryVJDtwvuczphF0Arln9R8F CbrEz9bC9LYNva6hrFvqfS03mTJBKwe76gpZjlOISsvJ7DeKRPlSqLQo36gedP1L4OI/ MmJN9VciAsELDEcqxoLH/i9HTkBcAyYapsv1OR/C6u5BynWw6KPebDqvNvhDzfUmZoPS COnRnSq8u03rSOqZ3HyaQEmE7Yq5md8tqUGrrc/eCApaaYIOHfns4CHRsvEurZDECNIN 2yUg== X-Gm-Message-State: AD7BkJJUmSk/f8MQdZAWZGXh056DIV8n9PztaXyyAJ8tY9UF7Y4SZRO1HoG5sn611JLoZtRCGX0ezFbPjo6fmgr5 X-Received: by 10.157.14.125 with SMTP id n58mr2471596otd.13.1458766606959; Wed, 23 Mar 2016 13:56:46 -0700 (PDT) MIME-Version: 1.0 Received: by 10.202.198.8 with HTTP; Wed, 23 Mar 2016 13:56:32 -0700 (PDT) In-Reply-To: References: <817F2FBA-9A93-4C6E-BAE0-B4D801136E57@apache.org> <75C231D0-8AEC-4F6C-B8CC-BF024F4836C7@gmail.com> From: Dan Halperin Date: Wed, 23 Mar 2016 13:56:32 -0700 Message-ID: Subject: Re: Capability matrix question To: dev@beam.incubator.apache.org Content-Type: multipart/alternative; boundary=001a11371cfe6b49cb052ebd9144 --001a11371cfe6b49cb052ebd9144 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable +1 @Amit =3D> -1 to Counter but +1 to Metric. On Wed, Mar 23, 2016 at 1:43 PM, Amit Sela wrote: > IMHO Counters just count.. Metrics measure things, so I think metrics > sounds better. Accumulators and Aggregators would have been good as well = if > they weren't so overloaded. > That's just my thoughts here though.. > > On Wed, Mar 23, 2016 at 10:38 PM Robert Bradshaw > wrote: > > > +1 to renaming this. [P]Counter is another option. > > > > On Wed, Mar 23, 2016 at 9:12 AM, Kenneth Knowles > > > wrote: > > > +1 to considering "metric" / PMetric / etc. > > > > > > On Wed, Mar 23, 2016 at 8:09 AM, Amit Sela > wrote: > > > > > >> How about "PMetric" ? > > >> > > >> On Wed, Mar 23, 2016, 16:53 Frances Perry wrote: > > >> > > >>> > > >>>>> Perhaps I'm unclear on what an =E2=80=9CAggregator=E2=80=9D is. I= assumed that a > line > > >>>>> such as the following: > > >>>>> > > >>>>> PCollection> meanByName =3D > > >>>>> dataPoints.apply(Mean.perKey()); > > >>>>> > > >>>>> =E2=80=A6would be considered an Aggregator, since it applies a me= an > > aggregation > > >>>>> over a window. Is that correct, with respect to the Beam > > terminology? If > > >>>>> not, what would an example of an Aggregator be? > > >>>>> > > >>>> > > >>> Ah, we may have some slightly confusing terminology here. > > >>> > > >>> In that code snippet you are using a PTransform (Mean.perKey) to > > combine > > >>> a PCollection using the Mean CombineFn > > >>> < > > > https://github.com/apache/incubator-beam/blob/c199f085473cfcd79014d0a022b= 5ce3fdd4863ec/sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Co= mbine.java#L359 > > >. > > >>> An Aggregator > > >>> < > > > https://github.com/apache/incubator-beam/blob/211e76abf9ba34c35ef13cca279= cbeefdad7c406/sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Ag= gregator.java#L54 > > > > > >>> takes a CombineFn and applies it continuously within a DoFn. So it'= s > > more > > >>> analogous to a 'counter'. You can see an example of aggregators in > > >>> DebuggingWordCount > > >>> < > > > https://github.com/apache/incubator-beam/blob/master/examples/src/main/ja= va/com/google/cloud/dataflow/examples/DebuggingWordCount.java#L129 > > > > > >>> . > > >>> > > >>> We never really used the term *aggregation *to refer to a general s= et > > of > > >>> PTransforms until we started describing things to the community. Bu= t > > it is > > >>> a useful word, so we've ended up in a bit of confusing state. Maybe > we > > >>> should consider renaming Aggregator? Something like "metric" might = be > > >>> clearer. > > >>> > > >>> > > > --001a11371cfe6b49cb052ebd9144--