Wie die Verkettung von einem string und einer Spalte in einem dataframe in der Funke?

Habe ich das heutige Datum als string. Ich brauche, um zu verketten, es mit einem Zeit-Wert, der vorhanden ist, wie eine Spalte in einem dataframe.

Wenn ich versuche, bekomme ich String Index out of bounds Ausnahme.

Mein code:

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

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

Erwartete Ausgabe:

2016-12-10 05:00 
2016-12-10 22:30
InformationsquelleAutor Dasarathy D R | 2016-12-10
  1. 3
    **Please refer to below Scala code for string concat in prefix and postfix way.**


import org.apache.spark.sql.functions._
val empDF =  MongoSpark.load(spark, readConfig) //dataframe empDF is loaded from Mongo DB using MongoSpark 

val prefixVal= "PrefixArkay " //variable string
val postfixVal= " PostfixArkay"

//Prefix
val finalPreDF = ipDF.withColumn("EMP", concat(lit(prefix),empDF.col("EMP")) )
println("finalPreDF.show-> " + finalPreDF.show())

//Output will be as below
+-------------------+
|                EMP|
+-------------------+
|PrefixArkay DineshS|
|+------------------+


val finalPostDF = ipDF.withColumn("EMP", concat(empDF.col("EMP"),lit(postfixVal)) )
println("finalPostDF.show-> " + finalPostDF .show())

//Output will be as below
+--------------------+
|                 EMP|
+--------------------+
|DineshS PostfixArkay|
|+-------------------+
    • Leuchtet nicht in Python 2.7 ?
    InformationsquelleAutor Dinesh Shinkar
  2. 2

    Können Sie es tun, wie unten.

    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

    Dies wird Ihnen

    +----------------+
|        datetime|
+----------------+
|2016-12-10 05:00|
|2016-12-10 22:30|
+----------------+
    InformationsquelleAutor abaghel
Schreibe einen Kommentar