Я пытаюсь написать Hive UDF, используя Scala.Этот UDF должен выполнить запрос к другой таблице улья и вернуть полученное значение
Например.У меня есть основная таблица в улье со столбцами emp_id, start_date, end_date, salary.Я пытаюсь придумать uive udf, используя scala для создания функции (getSal), где я могу передать id и некоторую дату и получить эффективную зарплату для этого id в другом запросе hive как select *, getSal (emp_id, прошло_date) какзарплата из какой-то таблицы;
Можете ли вы сказать мне, как этого добиться?
примечание - я могу получить подробности, соединив мою таблицу с главной таблицей и выполнив предложение между предложениями, но хотел бы изучить решение UDF.