Guest User

Untitled

a guest
Jun 21st, 2018
293
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.13 KB | None | 0 0
  1. val todaydate = LocalDate.now().toString()
  2. println(todaydate) // o/p: 2016-12-10
  3.  
  4. val todayrec_cutoff = todaydate + (" ") + df.col("colname")
  5.  
  6. 2016-12-10 05:00
  7. 2016-12-10 22:30
  8.  
  9. import java.time.LocalDate
  10.  
  11. val df = Seq(("05:00"), ("22:30")).toDF("time")
  12. df.show
  13. val todaydate = LocalDate.now().toString()
  14. val df2 = df.select(concat(lit(todaydate+ " "),df.col("time"))).toDF("datetime");
  15. df2.show
  16.  
  17. +----------------+
  18. | datetime|
  19. +----------------+
  20. |2016-12-10 05:00|
  21. |2016-12-10 22:30|
  22. +----------------+
  23.  
  24. val prefixVal= "PrefixArkay " //variable string
  25. val prefixVal= " PostfixArkay"
  26.  
  27. //Prefix
  28. val finalPreDF = ipDF.withColumn("EMP", concat(lit(prefix),empDF.col("EMP")) )
  29. println("finalPreDF.show-> " + finalPreDF.show())
  30.  
  31. //Output will be as below
  32. +-------------------+
  33. | EMP|
  34. +-------------------+
  35. |PrefixArkay DineshS|
  36. |+------------------+
  37.  
  38.  
  39. val finalPostDF = ipDF.withColumn("EMP", concat(empDF.col("EMP"),lit(prefix)) )
  40. println("finalPostDF.show-> " + finalPostDF .show())
  41.  
  42. //Output will be as below
  43. +--------------------+
  44. | EMP|
  45. +--------------------+
  46. |DineshS PostfixArkay|
  47. |+-------------------+
Add Comment
Please, Sign In to add comment