Интересно, как я могу получить схему ввода в функции exec(), когда я создаю UDF в Piglatin. Я могу получить схему из функции outputSchema(), но похоже, что результат не может быть использован бэкэнд-функциями. Любые подсказки будут высоко оценены!

Скажем, у нас есть следующая энергонезависимая UDF: Function Twice(ByRef x As Double) As Double Application.Volatile False Twice = 2 * x End Function который вводим в ячейку A1 со ссылкой на ячейку A2 , т.е. в A1 ставим: =...

Я использую ToDate UDF в свинье для создания поля даты и времени. Вводится в формате гггг-мм-дд. ToDate(sch_trans_dt,'yyyy-MM-dd','Etc/GMT+7') генерирует значение с двоеточием в поле отметки времени как 2015-11-26T00:00:00.000- 07:00 Есть ли способ...

Я вызываю UDF из выбранного запроса, однако во время запроса я вижу следующую ошибку. Кто-нибудь знает, в чем проблема? Я проверил Accounting_Date, он имеет допустимые значения даты типа 28.06.2015. Error: Bad number for Accounting_Date Error...

У меня есть Pig UDF, который поглощает некоторые данные, а затем пытается преобразовать эти данные минимальным образом. my_data = LOAD 'path/to/data' USING SomeCustomLoader(); my_other_data = FOREACH my_data GENERATE MyUDF(COL_1, COL_2, $param1,...

Я пишу hive-UDTF для разрешения IP-адреса путем загрузки файла .dat в HDFS, но встречаю ошибку: java.io.FileNotFoundException: hdfs:/THE_IP_ADDRESS:9000/tmp/ip_20170204.dat (Permission denied) Но на самом деле и каталог dfs /tmp, и файл...