Spark Scala中如何解析字符串并转换为Seq序列？

假设你要处理的是类似"[abc, def, ghi]"这样的字符串，想要转换成Scala的Seq，可以按以下场景分别实现：

场景1：生成包含字符串字面量的Seq #

如果目标是创建Seq("abc", "def", "ghi")这种元素为字符串的序列，直接通过字符串操作即可完成：

val input = "[abc, def, ghi]"
val seq = input.stripPrefix("[").stripSuffix("]")
  .split(",")
  .map(_.trim)
  .filter(_.nonEmpty)
  .toSeq
// 执行后seq的值为: Seq("abc", "def", "ghi")

场景2：引用已定义的变量生成Seq #

如果abc、def是代码中已定义的变量，想要直接引用这些变量生成序列，需要用到反射机制（编译期无法动态解析变量名）：

import scala.reflect.runtime.universe._

val input = "[abc, def, ghi]"
// 先清理字符串得到变量名列表
val varNames = input.stripPrefix("[").stripSuffix("]")
  .split(",")
  .map(_.trim)
  .filter(_.nonEmpty)

// 获取当前类的反射镜像
val mirror = runtimeMirror(getClass.getClassLoader)
val classMirror = mirror.reflect(this)
val classSymbol = mirror.classSymbol(getClass)

// 逐个解析变量并收集到Seq中
val seq = varNames.map { name =>
  val termSymbol = classSymbol.info.decl(TermName(name)).asTerm
  classMirror.reflectField(termSymbol).get
}.toSeq

注意：这种方式依赖变量的可见性，仅适用于运行时可访问的变量，非特殊场景更推荐场景1的实现方式。

场景3：处理复杂格式的输入 #

如果输入字符串可能包含嵌套结构、转义字符等复杂情况，建议用JSON解析库（比如Circe）来避免手动分割的漏洞：

import io.circe.parser._

val input = "[abc, def, ghi]"
// 先将元素转为合法JSON格式的字符串
val jsonInput = input.replaceAll("([a-zA-Z0-9_]+)", "\"$1\"")
parse(jsonInput) match {
  case Right(json) =>
    val seq = json.as[Seq[String]].getOrElse(Seq.empty)
    // 成功解析后seq为: Seq("abc", "def", "ghi")
  case Left(error) =>
    println(s"解析失败: ${error.getMessage}")
}

内容的提问来源于stack exchange，提问作者8919_racso