Retired_mod
Esteemed Contributor III

Hi @seeker, There are only 2 ways I can think of to do it:

  • Write a UDF.
  • Write customized MapReduce logic instead of using Spark SQL.
But they are kind of the same. So I would say UDF is a good solution.