Spark單引號錯誤

Question

我有一個DataFrame（Apache Spark 1.5）。 我想要使用spark sql上下文來添加新列以獲取新列，其中所有原始數據都包含單引號。

我的代碼：

df.registerTempTable("tempdf"); 
df = df.sqlContext().sql("SELECT *, \" \\\" \" as quoteCol FROM tempdf"); 

執行星火拋出一個異常後：

Exception in thread "main" java.lang.RuntimeException: [1.44] failure: ``union'' expected but ErrorToken(end of input) found 

SELECT *, " \" " as quoteCol FROM tempdf 
             ^
    at scala.sys.package$.error(package.scala:27) 
    at org.apache.spark.sql.catalyst.AbstractSparkSQLParser.parse(AbstractSparkSQLParser.scala:36) 
    at org.apache.spark.sql.catalyst.DefaultParserDialect.parse(ParserDialect.scala:67) 
    at org.apache.spark.sql.SQLContext$$anonfun$2.apply(SQLContext.scala:211) 
    at org.apache.spark.sql.SQLContext$$anonfun$2.apply(SQLContext.scala:211) 
    at org.apache.spark.sql.execution.SparkSQLParser$$anonfun$org$apache$spark$sql$execution$SparkSQLParser$$others$1.apply(SparkSQLParser.scala:114) 
    at org.apache.spark.sql.execution.SparkSQLParser$$anonfun$org$apache$spark$sql$execution$SparkSQLParser$$others$1.apply(SparkSQLParser.scala:113) 
    at scala.util.parsing.combinator.Parsers$Success.map(Parsers.scala:137) 
    ... 

下一個代碼正常工作，並與單個字符添加新行：

df.registerTempTable("tempdf"); 
df = df.sqlContext().sql("SELECT *, \" q \" as quoteCol FROM tempdf"); 

什麼時我做錯了？

Answer 1

SQL字符串應使用單引號：

sqlContext().sql("SELECT *, '\"' AS quoteCol FROM tempdf");