标签: nscala-time

如何在Spark中将unix时间戳转换为日期

我有一个带有unix时间戳列的数据框(例如,1435655706000),我想将其转换为格式为'yyyy-MM-DD'的数据,我尝试了nscala-time但它不起作用.

val time_col = sqlc.sql("select ts from mr").map(_(0).toString.toDateTime)
time_col.collect().foreach(println)
Run Code Online (Sandbox Code Playgroud)

我收到错误:java.lang.IllegalArgumentException:格式无效:"1435655706000"格式错误为"6000"

datetime timestamp scala apache-spark nscala-time

31
推荐指数
6
解决办法
7万
查看次数

迭代日期范围(scala方式)

鉴于开始日期和结束日期,我希望白天使用foreach,map或类似函数对其进行迭代.就像是

(DateTime.now to DateTime.now + 5.day by 1.day).foreach(println)
Run Code Online (Sandbox Code Playgroud)

我正在使用https://github.com/nscala-time/nscala-time,但如果我使用上面的语法,我会返回一个joda Interval对象,我怀疑它也不是一系列日期,而是一种范围毫秒.

编辑:这个问题已经过时了.正如joda主页上所建议的那样,如果你使用的是java 8,你应该从java.time开始或者迁移到java.time.

iteration datetime scala nscala-time

10
推荐指数
3
解决办法
2万
查看次数

Scala使用nscala-time获得当前时间毫秒

我想在millis中获取当前时间

DateTime.now.millis
Run Code Online (Sandbox Code Playgroud)

但我明白了

Property[millisOfSecond]
Run Code Online (Sandbox Code Playgroud)

使用nscala-time以毫秒获得当前时间的方法是什么?

我想这样做,使用相同的库

scala nscala-time

8
推荐指数
2
解决办法
2万
查看次数

如何根据数据框中的另一个星期添加一个新的列?

我在数据框中有一个字段,当前格式化为字符串(mm/dd/yyyy),我想在该数据框中创建一个新列,该字段具有该字段的星期名称(即星期四).我已经进口了

import com.github.nscala_time.time.Imports._
Run Code Online (Sandbox Code Playgroud)

但我不知道从哪里开始.

scala apache-spark nscala-time

2
推荐指数
1
解决办法
5417
查看次数