Me gustaría acceder a un archivo desde mi llamada udf. Este es mi guión:

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)}; 

El tarro está registrado. La ruta es real a mis hdfs, donde los archivos realmente existen. Se hace la llamada. Pero parece que el archivo no está descubierto. Tal vez porque estoy tratando de acceder al archivo en hdfs.

¿Cómo puedo acceder a un archivo en hdfs, desde mi llamada java de UDF?