Вопросы по теме 'udf'

Латинская свинья присоединиться по полю
У меня есть проблема, связанная с латынью Pig: У меня есть эти данные ниже (в одной строке): A = LOAD 'records' AS (f1:chararray, f2:chararray,f3:chararray, f4:chararray,f5:chararray, f6:chararray); DUMP A;...
174 просмотров
schedule 20.08.2022

ОШИБКА 1070 Apache Pig, использующая встроенную UDF
Это , это и this не решил мою проблему. Все они создают свои собственные UDF. Я хочу использовать встроенную UDF. Любой встроенный UDF. Я получаю ту же или похожую ошибку для каждой UDF, которую я пробовал. FOO = LOAD...
756 просмотров

Передать несколько параметров в UDF Pig Filter
Я новичок в написании сценариев Pig. Я хочу передать несколько параметров в UDF-фильтр Pig, но получаю сообщение об ошибке «Недопустимая скалярная проекция: столбец должен быть спроецирован из отношения, чтобы его можно было использовать в качестве...
1269 просмотров
schedule 12.11.2022

Сделать вызов API как часть UDF в BigQuery — возможно?
Мне интересно, можно ли сделать вызов API для API геокодирования карт Google в UDF в BigQuery? У меня есть геополя Google Analytics, такие как { "geoNetwork_continent": "Europe", "geoNetwork_subContinent": "Eastern Europe",...
1943 просмотров

java.lang.NullPointerException в UDF в PIG
мой UDF преобразует данный ввод в ВЕРХНИЙ регистр package myudfs; import java.io.IOException; import org.apache.pig.EvalFunc; import org.apache.pig.data.Tuple; public class UPPER extends EvalFunc<String> { public String exec(Tuple input)...
654 просмотров

Сравните два диапазона: классический диапазон и диапазон значений, разделенных запятыми, в одной ячейке
Предположим, у меня есть диапазон значений: 6 2 4 7 8 7 1 5 1 9 4 6 8 8 1 7 4 2 И отдельно в одной ячейке: "1, 4, 9" Мне нужно сравнить эти значения в одной ячейке с заданным диапазоном. В случае совпадения - напишите "Да", если нет - "Нет"....
65 просмотров
schedule 19.05.2023

Можно ли использовать MySQL UDF на Amazon RDS?
Мне нужно отправить HTTP-запрос при изменении базы данных, поэтому я использую расширение mysqludf. Он работает локально, но как заставить его работать и на Amazon RDS? Если это невозможно, мне нужно решение для использования триггера MySQL вместе...
3008 просмотров
schedule 10.08.2022

Сведение пакета данных в Pig
Предположим, у меня есть куча пакетов данных, сгенерированных из пользовательской функции Pig, которая содержит несколько кортежей строк. Как я могу вытащить их все из пакетов данных и просто сделать каждую строку своей собственной «строкой» данных....
268 просмотров
schedule 25.02.2023

Можно ли получить уведомление от MySQL о запуске программы?
Я хотел бы знать, возможно ли, чтобы, например, программа python ожидала ввода, и когда изменение базы данных происходит в определенной таблице, она уведомляла бы программу python с информацией, которую я хочу получить из этой точной таблицы....
44 просмотров
schedule 02.05.2023

Можете ли вы создать пользовательскую функцию BigQuery, которая генерирует списки таблиц, а не работает со строками?
Я просматриваю документацию по пользовательским функциям для BigQuery, но мне нужно определить функцию, чтобы упростить процесс запроса нескольких таблиц. У меня есть люди, которые должны делать такие вещи: SELECT * FROM...
454 просмотров
schedule 15.09.2022

Hive UDF обрабатывает URL-адреса
Я создал пользовательскую функцию Hive, которая анализирует URL-адрес. URL-адрес содержит параметры запроса. Однако, когда я анализирую ввод в своей пользовательской функции, такие символы, как «=» и «&», преобразуются в тарабарщину....
303 просмотров
schedule 07.04.2023

Перезагрузка UDF в PySpark
Я использую PySpark (внутри Jupyter Notebook, который подключается к Spark-кластеру) и некоторые UDF. UDF принимает список в качестве дополнительного параметра, и я создаю UDF следующим образом: my_udf = F.udf(partial(my_normal_fn,...
269 просмотров
schedule 05.06.2024

Сопоставьте любое слово внутри ячейки с любым словом в диапазоне ячеек
У меня есть список фраз. Я хотел бы проверить, соответствуют ли какие-либо новые термины этому списку частично по словам. Я ищу код для реализации нечеткого сопоставления в списке, чтобы вернуть ячейку с близким совпадением. Пример данных:...
1361 просмотров
schedule 09.01.2023

Ошибка Spark scala udf, если еще
Я пытаюсь определить udf с помощью функции getTIme для spark scala udf, но получаю сообщение об ошибке error: illegal start of declaration . Что может быть ошибкой в ​​синтаксисе и вернуть дату, а также, если есть исключение синтаксического анализа...
1711 просмотров
schedule 02.05.2023

UDF для возврата отформатированного числа
Иногда мне нравится отображать числа вместе с текстом в одной ячейке. Для этого я специально форматирую ячейку, например, 0,00 "test", например. ячейка A1 с формулой =PI() , но отформатированная в пользовательском формате 0.00" test" , вернет...
570 просмотров
schedule 31.12.2022

Итерируемая функция Spark CUSUM
Я все еще довольно новичок в Spark, и я изо всех сил пытаюсь реализовать повторяющуюся функцию. Я надеюсь, что кто-то может мне помочь? В частности, я пытаюсь реализовать статистику управления CUSUM : $ S_i = \max (0, S_{i-1} + x_i - Target -...
301 просмотров

функция-член класса scala как UDF
Я пытаюсь определить функцию-член в классе, который будет использоваться как UDF при анализе данных из файла json. Я использую трейт для определения набора методов и класса для переопределения этих методов. trait geouastr { def...
646 просмотров
schedule 01.04.2024

UDF, относящаяся к именованным ошибкам таблицы, когда активна другая книга
отредактировано для ясности, теперь, когда решение найдено Я новичок в VBA, создающий UDF. Этот UDF включает в себя ряд функций vlookup, которые ссылаются на таблицы Excel на других листах в книге, например: Twirecol =...
270 просмотров

Финансовый расчет BigQuery - Круглые вопросы
У меня есть реальная проблема с BigQuery и финансовыми расчетами. Кажется, что это копейки в зависимости от запроса, который не будет работать для моих нужд. Вот пример. Рассмотрим этот очень простой набор данных:...
446 просмотров

Преобразовать диапазон и вернуть его из пользовательской функции
Я пытаюсь написать очень простую UDF, которая будет принимать входной диапазон и возвращать другой диапазон. Каждая ячейка выходного диапазона должна быть равна ячейке входного диапазона плюс 1. Вот что у меня есть Public Function Addone(rng As...
159 просмотров
schedule 05.05.2022