python之如何从 Pig 中的 Python UDF 进行打印

我有一个用 Python 编写的用户定义函数，我从 Pig 脚本调用它。出于调试目的，我想打印出我的一些变量，但我的打印语句似乎没有任何效果。我如何从 Pig 中的 Python UDF 进行打印？

请您参考如下方法:

一般来说，如果您只是按照下面的示例打印(这对我有用)，它将转到将执行 UDF 的任务的日志。这里复杂的部分是找到通过作业跟踪器生成它的相关 map/reduce 任务(在 pig 11 中它更简单，因为 pig 将每个阶段写入标准输出)

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