让我们看几个例子。

val df = Seq(
  (1, "aaa"),
  (2, "b,c"),
  (3, "d$e"),
  (4, "f%g")
).toDF("x", "y")
df.show

+---+---+
|  x|  y|
+---+---+
|  1|aaa|
|  2|b,c|
|  3|d$e|
|  4|f%g|
+---+---+

当你的值中有逗号时，如果逗号与字段分隔符（如2,b,c）无法区分，Spark可以用引号将这些值括起来。默认情况下是双引号（如2,"b,c"），但你可以使用quote选项自定义它。

df.coalesce(1).write.mode("overwrite")
  .option("quote", "$")
  .csv("x")

1,aaa
2,$b,c$
3,$d\$e$
4,f%g

我们在这里使用了美元符号，不仅引用了b,c，而且由于d$e包含一个美元，所以也引用了它，而美元本身被省略了。
我不知道你为什么要这样做，但是你可以要求Spark不要使用escapeQuotes选项来转义包含引号字符的字段。

df.coalesce(1).write.mode("overwrite")
  .option("quote", "$")
  .option("escapeQuotes", false)
  .csv("x")

1,aaa
2,$b,c$
3,d$e
4,f%g

在这里，d$e没有被引用。
您还可以使用quoteAll强制它引用每个字段。

df.coalesce(1).write.mode("overwrite")
  .option("quote", "$")
  .option("quoteAll", true)
  .csv("x1")

$1$,$aaa$
$2$,$b,c$
$3$,$d\$e$
$4$,$f%g$

请注意，quoteAll = true 使 escapeQuotes 变得无关紧要。
如果不喜欢默认的反斜杠，可以使用escape为引号内的引号字符自定义转义符。

df.coalesce(1).write.mode("overwrite")
  .option("quote", "$")
  .option("escape", "%")
  .csv("x1")

1,aaa
2,$b,c$
3,$d%$e$
4,$f%g$

最后，请注意，f%g中有一个独立的转义字符，因此如果您希望对其进行转义，请使用charToEscapeQuoteEscaping。

df.coalesce(1).write.mode("overwrite")
  .option("quote", "$")
  .option("escape", "%")
  .option("quoteAll", true)
  .option("charToEscapeQuoteEscaping", "^")
  .csv("x1")

$1$,$aaa$
$2$,$b,c$
$3$,$d%$e$
$4$,$f^%g$

不，你不可能再深入一点，然后逃脱...