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.
--------
ThanksBest regards!
San.Luo
- 原始邮件 -
发件人：Pedro Rodriguez <ski.rodrig...@gmail.com>
收件人：luohu
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
hello guys: I have a DF and a UDAF. this DF has 2 columns, lp_location_id ,
id, both are of Int type. I want to group by id and aggregate all value of id
into 1 string. So I used a UDAF to do this transformation: multi Int values to
1 String. However my UDAF returns empty values as the
