哎呀。有时左连接比cogroup好。这就产生了一袋袋袋：

final_output = cogroup final_output by nodeid, new_edges by nodeid1;
final_output = foreach final_output generate flatten($1.hash_id) as hash_id, new_edges;
final_output = cogroup nodes_per_entity by hash_id, final_output by hash_id;

所以我把它改成：

final_output = join final_output by nodeid left, new_edges by nodeid1;
final_output = group final_output by hash_id;
final_output = foreach final_output generate group as hash_id, 
    final_output.(nodeid1, nodeid2, edge_pit, asset_id1, asset_id2) as new_edges;

现在它是一个普通的元组包（尽管由于左连接，其中一些元组有空值，但这更容易处理）。

这并不少见。我们也遇到了这个问题，所以我们为下一个版本的datafu添加了一个bagunion。正如您所描述的，它与bagconcat类似，只是它操作的是一袋袋而不是一组袋。