如何從Pig中的Python UDF打印？

我有一個用Python編寫的用戶定義函數，我從Pig腳本中調用。出於調試目的，我想打印出一些變量，但我的打印語句似乎沒有任何影響。如何從Pig中的Python UDF打印？如何從Pig中的Python UDF打印？

2012-07-24 BenH

使用Apache公共日誌工具，而不是（在豬11豬寫每一個階段到stdout更簡單）標準輸出？ 'import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; ＃參見pigLogger' – 2012-07-24 22:02:11

一般情況下，如果您只是按照下面的示例進行打印（適用於我），它將轉到執行UDF的任務日誌。這裏的複雜的部分是要找到相關的map/reduce而產生這種通過作業跟蹤任務

@outputSchema("schema:chararray") 
def convertBagToStr(acctBag): 
    #print len(acctBag) 
    #print acctBag 
    return "_".join([str(i[0]) for i in sorted(acctBag)])

來源

2014-01-02 12:23:02 nadavw

如何從Pig中的Python UDF打印？

回答

相關問題