mmend you create the serializer and deserializer pair once per
> thread.
>
> Kind regards,
> Herman
>
> On Tue, Aug 25, 2020 at 11:35 AM Robert Berke
> wrote:
>
>> Hi everyone
>>
>> Thanks Takeshi. I run into the same issue as Mark for my row to case
Hi everyone
Thanks Takeshi. I run into the same issue as Mark for my row to case class
converter:
def rowToCaseClass[C <: Product : TypeTag](r: Row)(implicit encs:
(ExpressionEncoder[Row], ExpressionEncoder[C])): C = {
val ir = encs._1.toRow(r)
encs._2.fromRow(ir)
}
So in Spark3.0 I would
