私はSparkにjsonファイルをインポートし、それを次のようにテーブルに変換しました。
myDF.registerTempTable("myDF")
次に、この結果テーブルに対してSQLクエリを実行します。
val newTable = sqlContext.sql("select column-1 from myDF")
ただし、列名にハイフンがあるため、エラーが発生しますcolumn-1
。Spark SQL でこれを解決するにはどうすればよいですか?
ベストアンサー1
バックティック(`)は機能するようです。
val newTable = sqlContext.sql("select `column-1` from myDF")
少なくとも Spark v1.3.x ではうまくいくはずです。