Как сериализовать DateTimeFormatter в Scala? - PullRequest
0 голосов
/ 20 июня 2019

Я использую DateTimeFormatter в Scala, и теперь он доставляет мне проблемы с сериализацией.

1 Ответ

0 голосов
/ 20 июня 2019

Ошибка происходит, потому что функция все еще определяется за пределами вашей карты. Переформатируйте, как работает ваша карта, чтобы включить DateTimeFormatter, определяемый внутри карты, следующим образом:

val evega = concat.map(_.split(",")).keyBy(_(0)).groupByKey().map{case (k, v) => {
    val formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd")
    val parsedDates = v.map(sa => LocalDate.parse(sa(1), formatter))
    parsedDates.max.getDayOfYear - parsedDates.min.getDayOfYear
}}
...