apache-pig - 在没有任何自定义 Pig UDF 的情况下将一袋元组连接成单个字符串

Question

如何连接一袋元组(例如:{(664),(823),(8),(47),(35),(27),(13),(16),(4) ,(8),(6)}) 使用不依赖于编写自定义 UDF 的 Pig Latin 转换为单个字符串？

Answer 1

这是一个 UDF 连接字符串的示例，这些字符串是包中的元组，假设每个元组中有 1 个项目(输出中的字符串定界符将为“_”):

#!/usr/bin/python

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

在 Pig 脚本中:

register '$udf_dir/myUDF.py' using jython as funcs;

a = foreach mygroup generate funcs.convertBagToStr(mybag) as bag_str;