You are right; you have to patch the code in the aggregate package.
On Fri, Apr 24, 2009 at 10:24 AM, Dan Milstein wrote:
> Runping,
>
> Thanks for the response. A question about case (2) below, (which is, in
> fact, what I want to do):
>
> - Is there any way to do this without patching the c
Runping,
Thanks for the response. A question about case (2) below, (which is,
in fact, what I want to do):
- Is there any way to do this without patching the code within the
aggregator package?
It sure doesn't look like it, but just to make sure.
Thanks again,
-Dan M
On Apr 24, 2009,
A couple of general goals behind of the aggregate package:
1. If you are application developers using aggregate package, you only need
to develop your own (user defined) valuator descriptor classes, which are
typically sub class of ValueAggregatorDescriptor. You can use
the existing aggregator typ
It really isn't documented anywhere. There is a small section in my book in
ch08 about it. It didn't make the alpha that is up of ch08 though.
On Thu, Apr 23, 2009 at 1:44 PM, Dan Milstein wrote:
> Hello all,
>
> I've been using streaming + the aggregate package (available via -reducer
> aggrega
Hello all,
I've been using streaming + the aggregate package (available via -
reducer aggregate), and have been very happy with what it gives me.
I'm interested in writing my own new aggregate functions (in Java)
which I could then access from my streaming code.
Can anyone give me pointers
