从pig中的别名加载数据

i1icjdpr  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(385)

我有一个这样的查询

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中。
谢谢您

ffscu2ro

ffscu2ro1#

a将进行以下工作:

%default TABLE_NAME `hive -e "SELECT ...your hive query to get the name from f5...;"`
C = LOAD 'DB.$TABLE_NAME' USING ...

我希望这有帮助。

相关问题