scala - 如何使用 1.4 DF API (Scala) 将两个字符串列或文字连接到字符串列

Question

当我尝试使用“+”函数将两个字符串列或一个文字与一个字符串列连接时，结果始终为空。

auction.select(col("item") ) show

+----+
|item|
+----+
|xbox|
+----+

所以专栏就好了。但是 + 运算符总是产生空值。concat我在 1.4 API 中找不到函数。

auction.select(col("item") + col("item")) show

+-------------+
|(item + item)|
+-------------+
|         null|
+-------------+

文字也是如此

auction.select(lit("Blue ") + col("item")) show


+--------------+
|(Blue  + item)|
+--------------+
|          null|
+--------------+

Answer 1

您始终可以将 DataFrame 注册为表，然后通过 SQL 进行查询：

auction.registerTempTable("auction")
val concatenated = sqlContext.sql("SELECT CONCAT(item, ' ',  item) FROM auction")