Конвертация даты в scala

Question

У меня есть сценарий, в котором я должен получить разницу между текущей датой и датами в столбце из dataframe. Я столкнулся с проблемой, когда взял текущую дату в localDate format, а дату в dataframe в типе данных date.

Также я попытался преобразовать текущий день в строку и преобразовать данные из dataframe to string, но не получаю ожидаемый результат, поскольку даты должны сравниваться с типами данных даты.

Я использовал следующий код:

import java.time.LocalDate
val localDate = LocalDate.now 

def computeCarAge(importvoices:DataFrame): DataFrame = {

val computeCarAgeUDF = udf (
    (aged: Date) =>
      if (aged < localDate ) {
        "from0to1year"
      } else if (aged <= localDate) {
        "from1to2years" }
)

Как сравнить java local date с spark.sql.date в формате (yyyy-MM-dd)? 1015 *

Answer 1

Вы можете преобразовать localDate of Java в тип данных Date, а затем сравнить с датой вашего кадра данных. Пример кода для преобразования LocalDate в тип данных Date:

Date date = Date.from(localDate.atStartOfDay(ZoneId.systemDefault()).toInstant());

Пример кода на Java, но вы можете написать его Scala-версию:)