Grokbase Groups Pig user April 2011
It's in 0.6, just not well documented :)

-----Original Message-----
From: "Dmitriy Lyubimov" <>
Cc: "Jonathan Coveney" <>
Sent: 4/15/2011 6:50 PM
Subject: Re: Algebraic UDF with one bag and one non-bag parameter
DEFINE func mypackage.myfunc(parameter);
Thanks! this is so cool. Holy grail, literary. i think this was not
available at least in 0.6? Since when is this available for eval

So you could also instantiate 2 versions.

2011/4/15 Dmitriy Lyubimov <>

is it possible to create an aggregating function with 2 parameters one
of which is bag and another one is not?

In particular, i want to use that to work around lack of function
invocation instance configuration.

say I have a function that can aggregate over some period of history ,
say, aggregate (days, sampleBag).

sampleBag is a bag of tuples in a form (value,time). So i want to use
it multiple times in the same script to aggregate exponentially over
30 days and another invocation instance to aggregate the same bag over
7 days. Exponential scale depends on this time parameter. So i want to
use it in something like
[truncated by sender]

Search Discussions

Discussion Posts


Related Discussions

Discussion Navigation
viewthread | post
posts ‹ prev | 4 of 4 | next ›
Discussion Overview
groupuser @
categoriespig, hadoop
postedApr 16, '11 at 1:27a
activeApr 17, '11 at 7:07p



site design / logo © 2021 Grokbase