回复:Re: question about UDAF

2016-07-12 Thread luohui20001
val s1 = buffer1.getAs[Int](0).toString() val s2 = buffer2.getAs[Int](0).toString() buffer1(0) = s1.concat(s2) } And the result is what I am expecting as attached file. Thanks&Best regards! San.Luo - 原始邮件 - 发件人:Pedro Rodriguez 收件人:luohui20...@sina.com 抄送人:user

Re: question about UDAF

2016-07-11 Thread Pedro Rodriguez
I am not sure I understand your code entirely, but I worked with UDAFs Friday and over the weekend ( https://gist.github.com/EntilZha/3951769a011389fef25e930258c20a2a). I think what is going on is that your "update" function is not defined correctly. Update should take a possibly initialized or in