加載數據

我這種格式加載數據

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;

現在C具有DB.Table_name有一個查詢..

請解釋我如何加載從table_name這是用C數據。

謝謝

來源

2016-01-08 Pruthvi

A將以下工作-A輪：

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

我希望這有助於。

來源

2016-01-09 05:35:56 kecso

嗨Kesco感謝您的工作我想使用它，但想知道如果F5帶回多個表，它是如何工作的。 – Pruthvi

如果您已定義了多個表，則可以使用bash工具來分析表名並將它們存儲在單獨的變量中。在剛剛使用定義的變量加載表格之後。 – kecso

如果你有不同數量的表（特別是有不同的模式），你可以使用嵌入式豬。 python https://pig.apache.org/docs/r0.9.1/cont.html#embed-python – kecso

回答

相關問題