Как загрузить файлы на кластере Hadoop, используя Apache PIG?

У меня есть скрипт свиньи, и мне нужно загружать файлы из локального кластера hadoop. Я могу перечислить файлы с помощью команды hadoop: hadoop fs –ls / repo / mydata, `но когда я попытался загрузить файлы в сценарии pig, это не удалось. оператор загрузки выглядит так:

in = LOAD '/repo/mydata/2012/02' USING PigStorage() AS (event:chararray, user:chararray)

сообщение об ошибке:

Message: org.apache.pig.backend.executionengine.ExecException: ERROR 2118: Input path does not exist: file:/repo/mydata/2012/02

любая идея? Спасибо

Ответы на вопрос(3)

Ваш ответ на вопрос