2014-05-15 75 views
1

我有一個包含未知數量字段的元組。我想扁平化元組,使得元組的每個元素創建一個新行(Bag扁平化的方式)豬:扁平化一個像袋子的元組


輸入:

student = { (A, B, (C, D, E, F)) } 

輸出:

student = { (A, B, C), 
      (A, B, D), 
      (A, B, E), 
      (A, B, F), 
      } 

如何實現這一目標?

+0

感謝Himanshu的格式化! –

回答

2

好的,讓它工作! 使用LinkedIn的DataFu UDF庫函數TransposeTupleToBag將元組轉換爲行李,然後展開行李。

類似這樣的: out = foreach student生成$ 0,$ 1,flatten(TransposeTupleToBag($ 2));