我有一个这样的查询
A = LOAD 'DB.Table_Name' Using org.apache.hive.hcatalog.pig.HCatLoader() as (f1:chararray, f2:chararray,f3:chararray,f4:chararray,f5:chararray,f6:chararray,f7:chararray,f8:chararray,f9:datetime,f10:chararray) ;
B = FILTER A BY f1 == 'Colum_Name';
C = FOREACH B GENERATE CONCAT('DB_Name.',f5);
Dump C;
现在我有了 DB.Table_name
..
请解释如何从 table_name
在c中。
谢谢您
1条答案
按热度按时间ffscu2ro1#
a将进行以下工作:
我希望这有帮助。