Форматирование входного файла в свинью

Question

Я использую свинью для данных analytic.So я хочу форматировать мой входной файл:

column1a,column2a,column3a 
column1b,column2b,column3b 
column1c,column2c,column3c 
column1d,column2d,column3d 

, и я хочу, чтобы генерировать этот вход в качестве вывода:

column1a|column2a|column3a 
column1b|column2b|column3b 
column1c|column2c|column3c 
column1d|column2d|column3d 

как сгенерировать это.

Answer 1

Попробуйте использовать этот код:

a = LOAD '<path>' using PigStorage(',') as (f1,f2,f3) 
b = FOREACH a GENERATE CONCAT(f1,'|',f2,'|',f3); 
dump b;