Как читать имя входного файла в piglatin

Question

У меня есть стандартные префиксы в именах файлов (QWERTY_123, POIUY_029 и т. Д.), Которые имеют одинаковые разделители все время. QWERTY ->, POIUY ->; Я разработал udf, который принимает префикс и сообщает разделителю. Теперь, как читать имена файлов в свинье, чтобы я разделил префикс на имя файла и получил разделитель для правильной загрузки файлов.

Answer 1

Постановление PigStorage в вашем заявлении LOAD, как указано в пункте 2 из this post. Он поместит имя файла в первое поле в каждой записи:

A = LOAD 'input' using PigStorage(',','-tagsource'); 
B = foreach A generate $0 as input_filename;