udf

0зной

2ответ

Мне было предложено создать определенную пользователем функцию в нашей среде Mainframe, которая проверяет строку поиска в более длинной строке. Единственный улов в том, что, если мы ищем пример для «A

2зной

1ответ

Схема для типа Any не поддерживается

Я пытаюсь создать искру UDF, чтобы извлечь пару (ключ, значение) из класса, определенного пользователем. Функция scala работает нормально, но когда я пытаюсь преобразовать ее в UDF в spark2.0, я сталк

0зной

1ответ

Spark UDF как параметр функции, UDF не находится в области функций

У меня есть несколько UDF, которые я хотел бы передать как аргумент функции вместе с кадрами данных. Одним из способов сделать это может быть создание UDF внутри функции, но это создаст и уничтожит не

-1зной

1ответ

Как написать PIG UDF для данных с разделителями вкладок и добавить метку времени с левой стороны?

Я пытаюсь написать PIG UDF для нижеприведенного входного файла образца, и я также указываю ожидаемый результат. Пожалуйста, помогите мне с шаблоном udf для того же или дайте мне знать, есть ли способ

1зной

1ответ

BIgQuery UDF Javascript работает в веб-интерфейсе, но не внедрен

Мне удалось получить запрос, работающий с веб-интерфейсом и UDF. Когда я поместил его в свой встроенный код, я получил ответ «400», «отсутствующий требуемый параметр». У меня есть код javascript в buc

2зной

1ответ

О том, как добавить новый столбец в существующий DataFrame со случайными значениями в Scala

У меня есть dataframe с паркетным файлом, и мне нужно добавить новый столбец с некоторыми случайными данными, но мне нужны эти случайные данные друг для друга. Это мой фактический код и текущая версия

0зной

1ответ

использование искра SQL UDF в dataframe API

Как я могу использовать UDF, который отлично работает в искре, как sparkSession.sql("select * from chicago where st_contains(st_makeBBOX(0.0, 0.0, 90.0, 90.0), geom)").show взят из из http://www.geo