2

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

4

1 回答 1

0

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

@outputSchema("schema:chararray")
def convertBagToStr(acctBag):
    #print len(acctBag)
    #print acctBag
    return "_".join([str(i[0]) for i in sorted(acctBag)])
于 2014-01-02T12:23:02.800 回答