如何翻譯Apache豬FOREACH生成語句火花?

[User15787040559]

如果你有以下Apache豬FOREACH生成語句:

XBCUD_Y_TMP1 = FOREACH(過濾XBCUD act_ind = = Y)生成cust_hash_key CONCAT (brd_abbr_cd ctry_cd) brdCtry: chararray, updt_dt_hash_key;

相當於在Apache火花是代碼:

XBCUD_Y_TMP1_DF = (XBCUD_DF .filter(坳(act_ind) = = " Y ") .select(坳(“cust_hash_key”), concat(坳(“brd_abbr_cd”),坳(“ctry_cd”)) .alias (“brdCtry”),坳(“updt_dt_hash_key”)))

[User15725630784]

相當於在Apache火花是代碼:

1. XBCUD_Y_TMP1_DF = (XBCUD_DF
2. .filter(坳(act_ind) = = " Y ")
3. .select(坳(“cust_hash_key”),
4. concat(坳(“brd_abbr_cd”),坳(“ctry_cd”)) .alias (“brdCtry”),
5. 坳(“updt_dt_hash_key”))
6. )