小编Ros*_*han的帖子

我正在使用Spark 2.0并寻找在Scala中实现以下功能的方法:

需要两个数据框列值之间的时间戳差异(以毫秒为单位).

Value_1 = 06/13/2017 16:44:20.044
Value_2 = 06/13/2017 16:44:21.067

两者的数据类型都是时间戳.

注意:对两个值应用函数unix_timestamp(列s)并减去工作但不要达到要求的毫秒值.

最终查询如下所示:

Select **timestamp_diff**(Value_2,Value_1) from table1

这应该返回以下输出:

1023毫秒

在哪里timestamp_diff是计算差异的函数,以毫秒为单位.