Friday, 13 December 2019

PIG

A = LOAD '/user/cloudera/movies' using PigStorage(',') as (col1: chararray,col2:chararray,col3:chararray,col4:chararray,col5:chararray);

DUMP A;

B = FOREACH A generate col1,col4,col5;

DUMP B;

No comments:

Post a Comment