在 Scala / Spark 中将纪元转换为日期时间

Question

我正在将表示 DateTime 的字符串转换为 unix_time（纪元），使用：

def strToTime(x: String):Long = { DateTimeFormat.
    forPattern("YYYY-MM-dd HH:mm:ss").parseDateTime(x).getMillis()/1000 }

像这样获取 Long 列表：

.map( p=> List( strToTime(p(0) ) ) )

我的问题是 - 向后转弯最简单的方法是什么？类似于：

def timeToStr(x: Long):String = { x*1000L.toDateTime}

我可以在上面的列表中使用（长）

已阅读Convert seconds since epoch to joda DateTime in Scala但无法成功应用

Answer 1

您有一个优先级问题 - .toDateTime 在应用 * 之前被应用到 1000L。把操作括起来，使调用顺序清晰：

def timeToStr(x: Long): String = { (x*1000L).toDateTime }

Answer 2

parseDateTime的反义词是print :)

def timeToStr(epochMillis: Long): String =
  DateTimeFormat.forPattern("YYYY-MM-dd HH:mm:ss").print(epochMillis)

Answer 3

遵循我的方法！

import java.util.Date
import java.text.SimpleDateFormat

def epochToDate(epochMillis: Long): String = {
    val df:SimpleDateFormat = new SimpleDateFormat("yyyy-MM-dd")
    df.format(epochMillis)
}

进行测试运行。

scala> epochToDate(1515027919000L)
res0: String = 2018-01-03

在 Scala / Spark 中将纪元转换为日期时间

convert epoch to datetime in Scala / Spark

datetime

scala

jodatime

apache-spark