Return-Path: X-Original-To: apmail-datafu-dev-archive@minotaur.apache.org Delivered-To: apmail-datafu-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 E86BE1780B for ; Sun, 12 Oct 2014 17:28:08 +0000 (UTC) Received: (qmail 16362 invoked by uid 500); 12 Oct 2014 17:28:08 -0000 Delivered-To: apmail-datafu-dev-archive@datafu.apache.org Received: (qmail 16316 invoked by uid 500); 12 Oct 2014 17:28:08 -0000 Mailing-List: contact dev-help@datafu.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@datafu.incubator.apache.org Delivered-To: mailing list dev@datafu.incubator.apache.org Received: (qmail 16304 invoked by uid 99); 12 Oct 2014 17:28:08 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 12 Oct 2014 17:28:08 +0000 X-ASF-Spam-Status: No, hits=-1997.8 required=5.0 tests=ALL_TRUSTED,HTML_MESSAGE,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Sun, 12 Oct 2014 17:28:06 +0000 Received: (qmail 16251 invoked by uid 99); 12 Oct 2014 17:27:46 -0000 Received: from reviews-vm.apache.org (HELO reviews.apache.org) (140.211.11.40) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 12 Oct 2014 17:27:46 +0000 Received: from reviews.apache.org (localhost [127.0.0.1]) by reviews.apache.org (Postfix) with ESMTP id 6CBA21D4301; Sun, 12 Oct 2014 17:27:42 +0000 (UTC) Content-Type: multipart/alternative; boundary="===============0890072847914819826==" MIME-Version: 1.0 Subject: Re: Review Request 25564: DATAFU-69: Create SelectFieldByName UDF - which, given a field who's value contains a field name, and *, returns the value of the field referenced by the field name From: "Russell Jurney" To: "Jonathan Coveney" , "Jakob Homan" , "Sam Shah" , "Matthew Hayes" Cc: "DataFu" , "Russell Jurney" Date: Sun, 12 Oct 2014 17:27:42 -0000 Message-ID: <20141012172742.24426.66898@reviews.apache.org> X-ReviewBoard-URL: https://reviews.apache.org Auto-Submitted: auto-generated Sender: "Russell Jurney" X-ReviewGroup: DataFu X-ReviewRequest-URL: https://reviews.apache.org/r/25564/ X-Sender: "Russell Jurney" References: <20140929005657.19177.7018@reviews.apache.org> In-Reply-To: <20140929005657.19177.7018@reviews.apache.org> Reply-To: "Russell Jurney" X-ReviewRequest-Repository: datafu X-Virus-Checked: Checked by ClamAV on apache.org --===============0890072847914819826== MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: 7bit > On Sept. 29, 2014, 12:56 a.m., Matthew Hayes wrote: > > Actually, I think renaming this to SelectStringFieldByName might make more sense. The way this UDF is used, you are looking for a tag that identifies a group. These are almost always chararrays. This doesn't limit the usefulness of the UDF at all. - Russell ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25564/#review54788 ----------------------------------------------------------- On Oct. 2, 2014, 4:19 p.m., Russell Jurney wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/25564/ > ----------------------------------------------------------- > > (Updated Oct. 2, 2014, 4:19 p.m.) > > > Review request for DataFu, Jonathan Coveney, Jakob Homan, Matthew Hayes, and Sam Shah. > > > Repository: datafu > > > Description > ------- > > Example use: > group_fields = LOAD '/e8/smalldata/group_fields.txt' AS (groupField:chararray); > with_group = CROSS group_fields, hour_rounded; > with_group = FOREACH with_group GENERATE group_fields::groupField AS groupField, > hour_rounded::sourceNameOrIp AS sourceNameOrIp, > hour_rounded::destinationNameOrIp AS destinationNameOrIp, > ...; > with_value_substitution = FOREACH with_group GENERATE ChooseFieldByValue(groupField, *) AS groupValue:tuple(value:chararray), *; > with_value_substitution = FOREACH with_value_substitution GENERATE > FLATTEN(groupValue) AS groupValue:chararray, > groupField, > foo, > bar, > ...; > all_success = FOREACH (GROUP with_value_substitution BY (groupField, groupValue, day)) GENERATE > FLATTEN(group) AS (seriesType, groupValue, day), > (int)COUNT_STAR(with_value_substitution) AS connections:int; > > > Diffs > ----- > > datafu-pig/src/main/java/datafu/pig/util/SelectFieldByName.java PRE-CREATION > datafu-pig/src/test/java/datafu/test/pig/util/SelectFieldByNameTest.java PRE-CREATION > > Diff: https://reviews.apache.org/r/25564/diff/ > > > Testing > ------- > > This UDF was used to replace a very inefficient pig script where macros that did many individual GROUP BY's took many minutes to plan. > > Testing: unit tests and used on real data on a cluster. > > > Thanks, > > Russell Jurney > > --===============0890072847914819826==--