init() is called for all the aggregation evaluators, then terminatePartial() is
called.
In your code, init() function is not overriding GenericUDAFEvaluator.init(Mode
m, ObjectInspector[] parameters). Hive calls GenericUDAFEvaluator.init.
Was the signature of the method wrong in your code?
Anyone know the answer to this?
Thanks,
Aurora
On Feb 15, 2011, at 8:53 AM, Aurora Skarra-Gallagher wrote:
Hi,
I wrote a simple UDAF for Hive 0.6 and I had to include null checks in
terminatePartial even though the object should never be null if init is
always called before
Hi,
I wrote a simple UDAF for Hive 0.6 and I had to include null checks in
terminatePartial even though the object should never be null if init is always
called before terminatePartial.
For instance, my init function:
public void init() {
result = new StringBuffer();