apache-pig

1зной

2ответ

Может ли Apache Pig загружать данные из STDIN вместо файла?

Я хочу использовать Apache pig для преобразования/объединения данных в два файла, но я хочу реализовать его шаг за шагом, а это значит, проверить его с реальных данных, но с небольшим размером (наприм

2зной

3ответ

Выполнение Свинья из Java-приложения

Можно ли запускать задания Apache Pig из приложения Java без разметки внешнего процесса? Кажется, что Pig и Hadoop написаны на Java, но на самом деле не предлагают Java API. Вместо того, чтобы полагат

0зной

2ответ

Ошибка чтения JSON с использованием elephantbird - PIG

Я не могу прочитать файл JSON с помощью ElephantBird и Pig. Я хочу знать, где я делаю ошибку. данных: { "nrcpts": "1", "src": "[email protected]", "sendmailid": "p6D0r0u1006229", "relay

0зной

2ответ

Сгенерировать записи на основе состояния во время проецирования в Pig Latin

Я хотел бы генерировать записи из существующей схемы на основе состояния , например. Я хочу сделать что-то вроде A = load 'data' using PigStorage() as (f1:int, f2:int); B = foreach A generate (f1 ==

1зной

2ответ

Загрузка таблицы Hbase с помощью Pig. Float дает FIELD_DISCARDED_TYPE_CONVERSION_FAILED

У меня есть таблица Hbase, который загружается через API HBase Java, как так: (. В случае, если переменная value является нормальным ява поплавок) put.add(Bytes.toBytes(HBaseConnection.FAMILY_NAME), B

4зной

4ответ

Как сгенерировать номер строки в свинье?

Я использую свинью для подготовки данных, и я столкнулся с проблемой, которая кажется простой, но я не могу иметь дело с: , например, у меня есть столбец имен name ------ Alicia Ana Benita Berta

1зной

2ответ

Pig Latin Фильтр списка строк

У меня есть файл, содержащий адреса и 3-файлы, содержащие ссылки, которые я хочу увидеть, если они существуют в первом файле Пример первого файла http://www.url1.com/xxxx/xxx/xxx/xxx/, http://www/urln

1зной

2ответ

Развернуть массив с Apache Pig

Я анализирую данные с помощью Apache pig и не могу найти способ расширения массива, если элементы. Вот схема я работаю, и пример желаемого выхода: (col1:int, col2:int, items:{ARRAY_ELEM:(name:chararra