Hi @Vaibhav Kumar, If you want to create a bag matching target table's structure, you can do as following: a = load 'file.csv' as PigStorage(',') as (x,y,w); b = foreach a generate x, y, (int)null as z, w; describe b; -- b: {x: int,y: int,z: int,w: int} ... View more

@Vaibhav Kumar recommendations from my colleagues are valid, you have strings in header row of your CSV documents. You can certainly filter by some known entity but there's a more advanced version of CSV Pig Loader called CSVExcelStorage. It is part of Piggybank library that comes bundled with HDP, hence the register command. You can pass different control parameters to it. Mortar blog is an excellent source of information on working with Pig http://help.mortardata.com/technologies/pig/csv. grunt> register /usr/hdp/current/pig-client/piggybank.jar; grunt> a = load 'BJsales.csv' using org.apache.pig.piggybank.storage.CSVExcelStorage(',', 'NO_MULTILINE', 'NOCHANGE', 'SKIP_INPUT_HEADER') as (Num:Int,time:int,BJsales:float); grunt> describe a; a: {Num: int,time: int,BJsales: float} grunt> b = limit a 5; grunt> dump b; output (1,1,200.1) (2,2,199.5) (3,3,199.4) (4,4,198.9) (5,5,199.0) notice I am not filtering any relation, I'm telling the loader to skip header outright, it saves a few key strokes and doesn't waste any cycles processing anything extra. ... View more