如何从pig中的python自定义项打印?

djmepvbi  于 2021-06-24  发布在  Pig
关注(0)|答案(1)|浏览(390)

我有一个用python编写的用户定义函数,我从pig脚本调用它。出于调试的目的,我想打印出一些变量,但是我的print语句似乎没有任何效果。如何在pig中打印python自定义项?

lnvxswe2

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)])

相关问题