sparkでデータフレーム内の文字列と列を連結する方法は？

Question

今日の日付は文字列として使用しています。私はそれをデータフレームの列として存在する時間値と連結する必要があります。

これを試してみると、私はString Index out of boundsの例外を受け取ります。

マイコード：

val todaydate = LocalDate.now().toString() 
println(todaydate) // o/p: 2016-12-10 

val todayrec_cutoff = todaydate + (" ") + df.col("colname") 

予想される出力：

2016-12-10 05:00 
2016-12-10 22:30 

Answer 1

あなたは以下のようにそれを行うことができます。

import java.time.LocalDate 

val df = Seq(("05:00"), ("22:30")).toDF("time") 
df.show 
val todaydate = LocalDate.now().toString() 
val df2 = df.select(concat(lit(todaydate+ " "),df.col("time"))).toDF("datetime"); 
df2.show 

これは、あなた

+----------------+ 
|  datetime| 
+----------------+ 
|2016-12-10 05:00| 
|2016-12-10 22:30| 
+----------------+ 

を与えます