我正在运行下面的spark sql:
test("SparkSQLTest") {
val spark = SparkSession.builder().master(s"local[1]").config("spark.sql.cbo.enabled", true).appName("SparkSQLTest").getOrCreate()
spark.createDataFrame(Seq(Person("Tom", 31), Person("Jack", 22))).createOrReplaceTempView("t")
val df = spark.sql("select name, '' XYZ, '' 水果, age from t ")
df.show(false)
}
我添加了一个常量,将其命名为水果
,但是Spark SQL无法识别它
发布于 2018-06-25 19:03:11
在创建spark session对象时,将编码选项设置为SJIS。这是一种字符编码
https://stackoverflow.com/questions/51020555
复制相似问题