Я работаю над анализом журналов доступа к AWS CloudFront. У меня есть код для загрузки строк файла raw_logs2 =LOAD 'file:///home/ec2-user/ENWRZAC68E00M.2011-02-28-18.72jA8eGh' USING PigStorage('\t') AS ( date: chararray, time:...

Я пытаюсь использовать нагрузку с источником данных в качестве корзины S3. load s3n://hourly-logprocessing/{2013090100,2013100501}/??????_0.gz' using some loader() не работает. load s3n://hourly-logprocessing/{201309????}/??????_0.gz...

У меня есть следующие данные (загруженные в переменную A): (a1:a2:a3|a4:a5:a6) (b1:b2:b3) (c1:c2:c3|c4:c5:c6|c7:c8:c9) Я хочу, чтобы мой окончательный результат был следующим: (a1:a2:a3) (a4:a5:a6) (b1:b2:b3) (c1:c2:c3) (c4:c5:c6)...

Я попытался включить сервер истории, используя ссылку, я мог сделать это только до тех пор, пока hdfs dis -mkdir -p / app-logs не работал, и я не мог продолжить. Теперь, когда я запускаю скрипт свиньи, который создает уменьшение карты, он не...

поэтому у меня есть следующая структура данных в свинье после описания: -------------------------------------------------------------------------------------------------------------------------------------------------------- |...

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