java - 如何将 ISO 8601 持续时间转换为秒

Question

我在 Spark 数据框中有一列作为
时间跨度
值在 iso 8601 持续时间内
例如:P0Y0M0DT0H5M35S .我想将该值转换为秒。 spark 或 Scala 中是否有一个函数可以帮助我做到这一点？我正在寻找一种方法并且没有成功
我试过持续时间

import java.time.Duration
java.time.Duration.parse("P0Y0M0DT0H5M35S")

这给了我错误:

java.time.format.DateTimeParseException: Text cannot be parsed to a Duration

我在将值传递给函数时做错了什么吗？我找到了这个文档
https://docs.oracle.com/javase/8/docs/api/java/time/Duration.html
如果我以这种方式成功，那么将不得不应用额外的逻辑来在整个数据框列上执行此操作

Answer 1

希望以下方法可以帮助您。

import org.apache.spark.sql.types._
import org.apache.spark.sql.functions._

val isoToSecondsUDF = udf( (value: String) => (java.time.Duration.parse("PT".concat(value.split("T")(1))).get(java.time.temporal.ChronoUnit.SECONDS)))

val df=Seq(("P0Y0M0DT0H5M35S")).toDF("value")

df.withColumn("seconds",isoToSecondsUDF($"value")).show()
/*
+---------------+-------+
|          value|seconds|
+---------------+-------+
|P0Y0M0DT0H5M35S|    335|
+---------------+-------+
*/