Pig - Python UDF問題

Question

我試圖在Pig中加載.mmdb文件，然後將它傳遞給python腳本。但是，我收到錯誤消息：「標量投影無效：db：需要從關係中投影列以將其用作標量」。我的代碼是：

REGISTER 'py_pigscript.py' USING jython AS myudf; 
log = LOAD 'test.txt' USING PigStorage(',') AS (x:int); 
db = LOAD 'data.mmdb'; 
result = FOREACH log GENERATE myudf.function(x,db); 

任何幫助，將不勝感激。謝謝！

-edit：

這個腳本的目標是從「的test.txt」各行提取值並傳遞給「data.mmdb」返回附加數據。

Answer 1

類似的問題在這裏討論[1]。在你的問題的情況下，代碼如下所示：

log = LOAD 'test.txt' USING PigStorage(',') AS (x:int); 
db = LOAD 'data.mmdb' AS (entry:(field_1:chararray, field_2....)); 
result = FOREACH log GENERATE myudf.function(x, db.entry); 

[1] Pig pass relation as argument to UDF