我有一个用python编写的用户定义函数,我从pig脚本调用它。出于调试的目的,我想打印出一些变量,但是我的print语句似乎没有任何效果。如何在pig中打印python自定义项?
lnvxswe21#
一般来说,如果你只是像下面的例子那样打印(这对我很有用),它将转到执行自定义项的任务日志。这里的复杂部分是找到相关的map/reduce任务,该任务通过job tracker生成(在pig 11中,它更简单,因为pig将每个阶段写入stdout)
@outputSchema("schema:chararray") def convertBagToStr(acctBag): #print len(acctBag) #print acctBag return "_".join([str(i[0]) for i in sorted(acctBag)])
1条答案
按热度按时间lnvxswe21#
一般来说,如果你只是像下面的例子那样打印(这对我很有用),它将转到执行自定义项的任务日志。这里的复杂部分是找到相关的map/reduce任务,该任务通过job tracker生成(在pig 11中,它更简单,因为pig将每个阶段写入stdout)