一种可能的解决方案是首先将输入字符串拆分为元组列表：

val split_input = input.split(",")
  .map(_.split("\\|").map(_.split(":")))
  .map(v => (v(1)(0), v(0)(1), v(1)(1)))

打印方式 foreach(println) 给予：

(customer_tmp,name,name)
(account,period,period)
(balance,id,balance_id)

接下来我们把通缉的逻辑放在一个 Map 为了便于修改：

val prefix_logic = Map("customer_tmp" -> "pm_", "account" -> "acct_", "balance" -> "bal_")

现在，我们可以应用逻辑并创建最后一个字符串：

val split_output = split_input.map(v => (v._2, prefix_logic.get(v._1).get + v._3))

val return_value = split_output.map(v => v._1 + "|" + v._2).mkString(",")

结果：

name|pm_name,period|acct_period,id|bal_balance_id