我编写了一个javaudf，它可以很好地处理一包元组。tuple.todelimitedstring是关键。

public class BagToString extends EvalFunc<String> {

    @Override
    public String exec(Tuple input) throws IOException {
        DataBag bag = (DataBag) input.get(0);
        Iterator<Tuple> bagIT = bag.iterator();
        String delimiter = "\t";

        StringBuilder sb = new StringBuilder();
        while(bagIT.hasNext()){
            Tuple tupleInBag = bagIT.next();
            sb.append(tupleInBag.toDelimitedString(delimiter)).append(delimiter);
        }

        return sb.toString();

    }
}

您需要为此编写自定义自定义自定义项。用python这样的语言很容易做到。做一些类似的事情：

@outputSchema("flat_bag:bag{}")
def flattenBag(bag):
    flat_bag = [item for tup in bag for item in tup]
    return flat_bag

只需将其放入.py文件并按如下方式加载：

REGISTER '/path/to/udfs.py' using jython as py_funcs;

然后像这样使用：

final1 = FOREACH final GENERATE email, py_funcs.flattenBag($1);