Thanks Raghavendra,
Could you be more specific about how I can use ExpressionEncoder()? More
specifically, how can I conform to the return type of Encoder>?
Thomas
On Sun, Apr 23, 2023 at 9:42 AM Raghavendra Ganesh
wrote:
> For simple array types setting encoder to ExpressionEncoder() should
For simple array types setting encoder to ExpressionEncoder() should work.
--
Raghavendra
On Sun, Apr 23, 2023 at 9:20 PM Thomas Wang wrote:
> Hi Spark Community,
>
> I'm trying to implement a custom Spark Aggregator (a subclass to
> org.apache.spark.sql.expressions.Aggregator). Correct me if
Hi Spark Community,
I'm trying to implement a custom Spark Aggregator (a subclass to
org.apache.spark.sql.expressions.Aggregator). Correct me if I'm wrong, but
I'm assuming I will be able to use it as an aggregation function like SUM.
What I'm trying to do is that I have a column of ARRAY and I
