Hive UDF для обработки массива целых чисел в Scala

Question

Я новичок в Scala, и мне нужно написать пользовательскую функцию для обработки столбцов с массивом целых чисел в Hive (тип array<int>).

Я пробовал:

import org.apache.hadoop.hive.ql.exec.UDF

class testUDF extends UDF {

  def evaluate(arr: Array[Int], txt: String): Boolean = {
    return false
  }

}

Но когда я попытался вызвать его в SQL, я получил ошибку:

No matching method for class ... with (array<int>, string). Possible choices: _FUNC_(struct<>, string)

Какой тип мне нужно использовать в Scala для работы со столбцами массивов в Hive?

Answer 1

После некоторого исследования я нашел определенный класс для этих случаев:

import org.apache.hadoop.hive.ql.udf.generic.GenericUDF;