java - Spark sql(1.4): Get current timestamp

标签 java scala apache-spark apache-spark-sql

我知道 Spark 1.5 及更高版本中有一个“current_timestamp”函数,但我们仍然使用 1.4。如何向设置为“当前时间戳”的 DataFrame 添加一列?

df.withColumn("date_inserted", ????)

最佳答案

简单的时间戳文字应该可以解决问题:

df.withColumn(
  "date_inserted",
  lit(java.sql.Timestamp.from(java.time.Instant.now)))

关于java - Spark sql(1.4): Get current timestamp,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38959349/

相关文章:

java - 如何反射(reflect)私有(private)静态嵌套子类?

java - 为什么有些 java eclipse 错误没有特定的代码行?

scala - 如何使用 SBT 下载静态文件并将其添加到项目中

java - 在 Scala 中重写 Spark Java 应用程序

apache-spark - Spark Dataframe 默认是如何分区的?

java - JFileChooser 自定义 - 将渐变绘制设置为 JFilechooser

java - Spring WebClient 和 client_credentials 授予

generics - 如何创建基于泛型类型返回对象的泛型 Scala 函数?

scala - 如何生成集合的成对组合,而忽略顺序?

apache-spark - 基本的Spark示例不起作用