Я хотел бы получить доступ к файлу из моего звонка в формате udf. Это мой сценарий:

files = LOAD '$docs_in' USING PigStorage(';') AS (id, stopwords, id2, file);
buzz = FOREACH files GENERATE pigbuzz.Buzz(file, id) as file:bag{(year:chararray, word:chararray, count:long)}; 

Баночка зарегистрирована. Путь к моим hdfs, где файлы действительно существуют. Звонок сделан. Но похоже, что файл не обнаружен. Может быть, потому что я пытаюсь получить доступ к файлу на hdfs.

Как я могу получить доступ к файлу в формате hdf из моего вызова UDF Java?