如何在Spark SQL中表示名称中包含空格的列

Question

我们已经尝试过用括号[column name]、单引号和双引号以及反引号将列名括起来，但都不起作用。

Spark SQL支持名称包含空格的列吗？

谢谢!

Answer 1

Backticks似乎工作得很好：

scala> val df = sc.parallelize(Seq(("a", 1))).toDF("foo bar", "x")
df: org.apache.spark.sql.DataFrame = [foo bar: string, x: int]
scala> df.registerTempTable("df")

scala> sqlContext.sql("""SELECT `foo bar` FROM df""").show
foo bar
a  

与DataFrame接口相同：

scala> df.select($"foo bar").show
foo bar
a   

所以它看起来是被支持的，尽管我怀疑它是不是被推荐的。

Answer 2

不要像在T-SQL中那样使用方括号，而是使用反号来包装列名`column name`。这是您运行SQL的时候。您还可以在spark SQL中使用Backticks对列名进行换行，但要使用zero323回答的三重引号。