Как преобразовать элементы ARRY в BAG в несколько строк, например: ниже Мой вклад: кортеж,...

Постановка проблемы Предположим, есть один текстовый файл журналов. Ниже приведены поля в файле....

Я читаю программирование свиней Аланом Гейтсом. Рассмотрим код: ratings = LOAD...

У меня есть список фильмов с датой выпуска.Я хочу получить список фильмов, которые новее данного...

Я новичок в Hadoop / Pig, и я только начал читать документы. Существует множество блогов по...

Мне нужно узнать максимальную сумму, потраченную на город вместе с продуктом. Моя реализация: A =...

Входные данные **Col1| Col2 | Col3 | Col4** 2 | 500 | 50 | 100 Как преобразовать столбцы в строки в...

REGISTER 'udf.py' using jython as myfunc; loadhtml = load './assignment/crawler'...

Я написал простой UDF на python для PIG @outputSchema("date: chararray") def...

При попытке сохранить вывод в файл CSV в Pig, команда выполняется успешно, но вместо имени файла...

Мой PIG-скрипт имеет следующую строку register 'foo.py' USING jython as foo; Файл foo.py...

Предположим, мои данные следующие: (XXX, {(1), (2), (3)}) Мне понадобится разница между кортежами...

Я пытался выполнить следующую команду в grunt .....................................................

В моем коде свиньи переменная event_date вычисляется следующим образом: SUBSTRING(case when...

150060275,NON-CRIMINAL,LOST PROPERTY,Monday,01/19/2015,14:00,MISSION,NONE,18TH ST / VALENCIA ST,-122

Я выполняю сценарий pig, который взаимодействует с HBase, и получаю следующую ошибку: Причина: java

Я ищу самый холодный час для каждого дня. Мои данные выглядят так: (2015/12/27,12AM,32.0)...

({(б, в), (д, е)}) * * тысяча один Я попробовал это с: (t1: tuple (B1: Bag {(a: chararray, b: a:...

У меня есть даты, похожие на следующие 3/30/2018 Я бы хотел разобрать месяц (3) для последующей...

Я загрузил данные в Hadoop с помощью Pig, но когда я выгружаю таблицу csv, похоже, мои данные были...

В интернете очень много картинок экосистем Hadoop, поэтому я изо всех сил пытаюсь понять, как...

У меня есть серия сценариев Pig, которые преобразуют сотни миллионов записей из нескольких...

Я работаю над проектом, который требует, чтобы я нашел среднее временное значение (например, час,...

Каким-то образом, если я использую grunt shell для выполнения сценария pig, он работает нормально,...

Есть ли хороший способ ранжировать столбец в Apache Pig после того, как вы его отсортировали?Еще...